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:

StorageEngine<RocksDBStoragePartition>, Closeable, AutoCloseable

public class RocksDBStorageEngine
extends AbstractStorageEngine<RocksDBStoragePartition>

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
AbstractStorageIterator	getIterator(int partitionId)
protected AbstractStoragePartition	getMetadataPartition()
Set<Integer>	getPersistedPartitionIds()
StorageEngineStats	getStats()
PersistenceType	getType()
void	setRocksDBServerConfig(RocksDBServerConfig rocksDBServerConfig)

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

addStoragePartitionIfAbsent, adjustStoragePartition, beginBatchWrite, checkDatabaseIntegrity, clearPartitionOffset, clearStoreVersionState, close, closeMetadataPartition, closePartition, containsPartition, delete, deleteWithReplicationMetadata, dropPartition, dropPartition, endBatchWrite, executeWithSafeGuard, 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

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

getMetadataPartition

protected AbstractStoragePartition getMetadataPartition()

Overrides:

getMetadataPartition in class AbstractStorageEngine<RocksDBStoragePartition>

getType

public PersistenceType getType()

getPersistedPartitionIds

public Set<Integer> getPersistedPartitionIds()

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

Specified by:

drop in interface StorageEngine<RocksDBStoragePartition>

Overrides:

drop in class AbstractStorageEngine<RocksDBStoragePartition>

setRocksDBServerConfig

public void setRocksDBServerConfig(RocksDBServerConfig rocksDBServerConfig)

getIterator

public AbstractStorageIterator getIterator(int partitionId)

Specified by:

getIterator in interface StorageEngine<RocksDBStoragePartition>

Overrides:

getIterator in class AbstractStorageEngine<RocksDBStoragePartition>

getStats

public StorageEngineStats getStats()