Package com.linkedin.venice.offsets

Class InMemoryStorageMetadataService

java.lang.Object

com.linkedin.venice.offsets.InMemoryOffsetManager

com.linkedin.venice.offsets.InMemoryStorageMetadataService

All Implemented Interfaces:

StorageMetadataService, OffsetManager

public class InMemoryStorageMetadataService
extends InMemoryOffsetManager
implements StorageMetadataService

In memory implementation of StorageMetadataService, should really only be used for tests

Constructor Summary

Constructors

Constructor	Description
InMemoryStorageMetadataService()

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 .
void	computeStoreVersionState(String topicName, Function<StoreVersionState,StoreVersionState> mapFunction)
StoreVersionState	getStoreVersionState(String topicName)	Gets the currently-persisted StoreVersionState for this topic.

Methods inherited from class com.linkedin.venice.offsets.InMemoryOffsetManager

clearOffset, getLastOffset, put

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

clearOffset, getLastOffset, put

Methods inherited from interface com.linkedin.davinci.storage.StorageMetadataService

getStoreVersionCompressionDictionary

Constructor Details

InMemoryStorageMetadataService

public InMemoryStorageMetadataService()

Method Details

computeStoreVersionState

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

Specified by:

computeStoreVersionState in interface StorageMetadataService

Throws:

VeniceException

clearStoreVersionState

public void clearStoreVersionState(String topicName)

Description copied from interface: StorageMetadataService

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

Specified by:

clearStoreVersionState in interface StorageMetadataService

Parameters:

topicName - to be cleared

getStoreVersionState

public StoreVersionState getStoreVersionState(String topicName)
                                       throws VeniceException

Description copied from interface: StorageMetadataService

Gets the currently-persisted StoreVersionState for this topic.

Specified by:

getStoreVersionState in interface StorageMetadataService

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