Class RocksDBStorageEngine
java.lang.Object
com.linkedin.davinci.store.AbstractStorageEngine<RocksDBStoragePartition>
com.linkedin.davinci.store.rocksdb.RocksDBStorageEngine
- All Implemented Interfaces:
StorageEngine<RocksDBStoragePartition>
,Closeable
,AutoCloseable
-
Field Summary
FieldsFields inherited from class com.linkedin.davinci.store.AbstractStorageEngine
METADATA_PARTITION_ID
-
Constructor Summary
ConstructorsConstructorDescriptionRocksDBStorageEngine
(VeniceStoreVersionConfig storeConfig, RocksDBStorageEngineFactory factory, String rocksDbPath, RocksDBMemoryStats rocksDBMemoryStats, RocksDBThrottler rocksDbThrottler, RocksDBServerConfig rocksDBServerConfig, InternalAvroSpecificSerializer<StoreVersionState> storeVersionStateSerializer, InternalAvroSpecificSerializer<PartitionState> partitionStateSerializer, boolean replicationMetadataEnabled) -
Method Summary
Modifier and TypeMethodDescriptioncreateStoragePartition
(StoragePartitionConfig storagePartitionConfig) void
drop()
Drop the whole storegetIterator
(int partitionId) protected AbstractStoragePartition
getStats()
getType()
void
setRocksDBServerConfig
(RocksDBServerConfig rocksDBServerConfig) Methods inherited from class com.linkedin.davinci.store.AbstractStorageEngine
addStoragePartition, adjustStoragePartition, beginBatchWrite, checkDatabaseIntegrity, clearPartitionOffset, clearStoreVersionState, close, closeMetadataPartition, closePartition, containsPartition, delete, deleteWithReplicationMetadata, dropPartition, dropPartition, endBatchWrite, get, get, get, getByKeyPrefix, getNumberOfPartitions, getPartitionIds, getPartitionOffset, getPartitionOrThrow, getPartitions, getReplicationMetadata, getRWLockForPartitionOrThrow, getStoreVersionName, getStoreVersionState, isClosed, put, put, putPartitionOffset, putReplicationMetadata, putStoreVersionState, putWithReplicationMetadata, reopenStoragePartition, restoreStoragePartitions, restoreStoragePartitions, suppressLogs, sync, toString, updateStoreVersionStateCache
-
Field Details
-
SERVER_CONFIG_FILE_NAME
- See Also:
-
-
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
-
getMetadataPartition
- Overrides:
getMetadataPartition
in classAbstractStorageEngine<RocksDBStoragePartition>
-
getType
-
getPersistedPartitionIds
-
createStoragePartition
public RocksDBStoragePartition createStoragePartition(StoragePartitionConfig storagePartitionConfig) - Specified by:
createStoragePartition
in classAbstractStorageEngine<RocksDBStoragePartition>
-
drop
public void drop()Description copied from class:AbstractStorageEngine
Drop the whole store- Specified by:
drop
in interfaceStorageEngine<RocksDBStoragePartition>
- Overrides:
drop
in classAbstractStorageEngine<RocksDBStoragePartition>
-
setRocksDBServerConfig
-
getIterator
- Specified by:
getIterator
in interfaceStorageEngine<RocksDBStoragePartition>
- Overrides:
getIterator
in classAbstractStorageEngine<RocksDBStoragePartition>
-
getStats
-