Package com.linkedin.davinci.store.rocksdb

Class RocksDBStorageEngine

java.lang.Object

com.linkedin.davinci.store.AbstractStorageEngine<RocksDBStoragePartition>

com.linkedin.davinci.store.rocksdb.RocksDBStorageEngine

All Implemented Interfaces:

Closeable, AutoCloseable

public class RocksDBStorageEngine
extends AbstractStorageEngine<RocksDBStoragePartition>

Nested Class Summary

Nested classes/interfaces inherited from class com.linkedin.davinci.store.AbstractStorageEngine

AbstractStorageEngine.StoragePartitionAdjustmentTrigger

Field Summary

Fields

Modifier and Type	Field	Description
static final String	SERVER_CONFIG_FILE_NAME

Fields inherited from class com.linkedin.davinci.store.AbstractStorageEngine

METADATA_PARTITION_ID

Constructor Summary

Constructors

Constructor

Description

RocksDBStorageEngine(VeniceStoreVersionConfig storeConfig, RocksDBStorageEngineFactory factory, String rocksDbPath, RocksDBMemoryStats rocksDBMemoryStats, RocksDBThrottler rocksDbThrottler, RocksDBServerConfig rocksDBServerConfig, InternalAvroSpecificSerializer<StoreVersionState> storeVersionStateSerializer, InternalAvroSpecificSerializer<PartitionState> partitionStateSerializer, boolean replicationMetadataEnabled)

Method Summary

Modifier and Type	Method	Description
RocksDBStoragePartition	createStoragePartition(StoragePartitionConfig storagePartitionConfig)
void	drop()	Drop the whole store
long	getCachedRMDSizeInBytes()
long	getCachedStoreSizeInBytes()
AbstractStorageIterator	getIterator(int partitionId)
Set<Integer>	getPersistedPartitionIds()
long	getRMDSizeInBytes()
long	getStoreSizeInBytes()
PersistenceType	getType()
boolean	hasMemorySpaceLeft()
void	setRocksDBServerConfig(RocksDBServerConfig rocksDBServerConfig)

Methods inherited from class com.linkedin.davinci.store.AbstractStorageEngine

addStoragePartition, addStoragePartition, adjustStoragePartition, beginBatchWrite, checkDatabaseIntegrity, clearPartitionOffset, clearStoreVersionState, close, closeMetadataPartition, closePartition, containsPartition, createSnapshot, delete, deleteWithReplicationMetadata, dropMetadataPartition, dropPartition, endBatchWrite, get, get, get, getByKeyPrefix, getCompressionStrategy, getMetadataPartition, getNumberOfPartitions, getPartitionIds, getPartitionOffset, getPartitionOrThrow, getPartitionSizeInBytes, getReplicationMetadata, getRWLockForPartitionOrThrow, getStoreVersionName, getStoreVersionState, isChunked, isClosed, isMetadataPartition, put, put, put, putPartitionOffset, putReplicationMetadata, putStoreVersionState, putWithReplicationMetadata, reopenStoragePartition, restoreStoragePartitions, restoreStoragePartitions, suppressLogs, sync, toString, updateStoreVersionStateCache

Methods inherited from class java.lang.Object

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

Field Details

SERVER_CONFIG_FILE_NAME

public static final String SERVER_CONFIG_FILE_NAME

See Also:

• Constant Field Values

Constructor Details

RocksDBStorageEngine

public RocksDBStorageEngine(VeniceStoreVersionConfig storeConfig,
 RocksDBStorageEngineFactory factory,
 String rocksDbPath,
 RocksDBMemoryStats rocksDBMemoryStats,
 RocksDBThrottler rocksDbThrottler,
 RocksDBServerConfig rocksDBServerConfig,
 InternalAvroSpecificSerializer<StoreVersionState> storeVersionStateSerializer,
 InternalAvroSpecificSerializer<PartitionState> partitionStateSerializer,
 boolean replicationMetadataEnabled)

Method Details

getType

public PersistenceType getType()

Specified by:

getType in class AbstractStorageEngine<RocksDBStoragePartition>

getPersistedPartitionIds

public Set<Integer> getPersistedPartitionIds()

Specified by:

getPersistedPartitionIds in class AbstractStorageEngine<RocksDBStoragePartition>

createStoragePartition

public RocksDBStoragePartition createStoragePartition(StoragePartitionConfig storagePartitionConfig)

Specified by:

createStoragePartition in class AbstractStorageEngine<RocksDBStoragePartition>

drop

public void drop()

Description copied from class: AbstractStorageEngine

Drop the whole store

Overrides:

drop in class AbstractStorageEngine<RocksDBStoragePartition>

getRMDSizeInBytes

public long getRMDSizeInBytes()

Overrides:

getRMDSizeInBytes in class AbstractStorageEngine<RocksDBStoragePartition>

getCachedRMDSizeInBytes

public long getCachedRMDSizeInBytes()

Overrides:

getCachedRMDSizeInBytes in class AbstractStorageEngine<RocksDBStoragePartition>

getStoreSizeInBytes

public long getStoreSizeInBytes()

Specified by:

getStoreSizeInBytes in class AbstractStorageEngine<RocksDBStoragePartition>

getCachedStoreSizeInBytes

public long getCachedStoreSizeInBytes()

Overrides:

getCachedStoreSizeInBytes in class AbstractStorageEngine<RocksDBStoragePartition>

hasMemorySpaceLeft

public boolean hasMemorySpaceLeft()

Overrides:

hasMemorySpaceLeft in class AbstractStorageEngine<RocksDBStoragePartition>

setRocksDBServerConfig

public void setRocksDBServerConfig(RocksDBServerConfig rocksDBServerConfig)

getIterator

public AbstractStorageIterator getIterator(int partitionId)

Overrides:

getIterator in class AbstractStorageEngine<RocksDBStoragePartition>