StorageMetadataService (venice API)

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

All Methods Instance Methods Abstract Methods Default Methods
Modifier and Type	Method	Description
`void`	`clearStoreVersionState(java.lang.String topicName)`	This will clear all metadata, including store-version state and partition states, tied to {@param topicName}.
`void`	`computeStoreVersionState(java.lang.String topicName, java.util.function.Function<StoreVersionState,StoreVersionState> mapFunction)`
`default java.nio.ByteBuffer`	`getStoreVersionCompressionDictionary(java.lang.String topicName)`	Tailored function for retrieving version's compression dictionary.
`StoreVersionState`	`getStoreVersionState(java.lang.String topicName)`	Gets the currently-persisted `StoreVersionState` for this topic.

Methods inherited from interface com.linkedin.venice.offsets.OffsetManager
clearOffset, getLastOffset, put

- Method Detail
  - computeStoreVersionState
```
void computeStoreVersionState(java.lang.String topicName,
                              java.util.function.Function<StoreVersionState,StoreVersionState> mapFunction)
                       throws VeniceException
```
    Throws:
    
    VeniceException
  - clearStoreVersionState
```
void clearStoreVersionState(java.lang.String topicName)
```
    This will clear all metadata, including store-version state and partition states, tied to {@param topicName}.
    
    Parameters:
    
    topicName - to be cleared
  - getStoreVersionState
```
StoreVersionState getStoreVersionState(java.lang.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 java.nio.ByteBuffer getStoreVersionCompressionDictionary(java.lang.String topicName)
```
    Tailored function for retrieving version's compression dictionary.