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 Details

    • computeStoreVersionState

      void 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.