Package com.linkedin.davinci.storage

Interface StorageMetadataService

All Superinterfaces:

OffsetManager

All Known Implementing Classes:

DeepCopyStorageMetadataService, InMemoryStorageMetadataService, MainIngestionStorageMetadataService, StorageEngineMetadataService

public interface StorageMetadataService
extends OffsetManager

This is a superset of the OffsetManager APIs, which also provide functions for storing store-version level state.

Method Summary

Modifier and Type	Method	Description
void	clearStoreVersionState(String topicName)	This will clear all metadata, including store-version state and partition states, tied to .
StoreVersionState	computeStoreVersionState(String topicName, Function<StoreVersionState,StoreVersionState> mapFunction)
default ByteBuffer	getStoreVersionCompressionDictionary(String topicName)	Tailored function for retrieving version's compression dictionary.
StoreVersionState	getStoreVersionState(String topicName)	Gets the currently-persisted StoreVersionState for this topic.

Methods inherited from interface com.linkedin.venice.offsets.OffsetManager

clearOffset, getLastOffset, put

Method Details

computeStoreVersionState

StoreVersionState computeStoreVersionState(String topicName,
 Function<StoreVersionState,StoreVersionState> mapFunction)
                                    throws VeniceException

Throws:

VeniceException

clearStoreVersionState

void clearStoreVersionState(String topicName)

This will clear all metadata, including store-version state and partition states, tied to .

Parameters:

topicName - to be cleared

getStoreVersionState

StoreVersionState getStoreVersionState(String topicName)
                                throws VeniceException

Gets the currently-persisted StoreVersionState for this topic.

Parameters:

topicName - kafka topic to which the consumer thread is registered to.

Returns:

an instance of StoreVersionState corresponding to this topic, or null if there isn't any.

Throws:

VeniceException

getStoreVersionCompressionDictionary

default ByteBuffer getStoreVersionCompressionDictionary(String topicName)

Tailored function for retrieving version's compression dictionary.