Class InMemoryStorageEngine
- java.lang.Object
-
- com.linkedin.davinci.store.AbstractStorageEngine<InMemoryStoragePartition>
-
- com.linkedin.davinci.store.memory.InMemoryStorageEngine
-
- All Implemented Interfaces:
java.io.Closeable,java.lang.AutoCloseable
public class InMemoryStorageEngine extends AbstractStorageEngine<InMemoryStoragePartition>
A simple non-persistent, in-memory store.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class com.linkedin.davinci.store.AbstractStorageEngine
AbstractStorageEngine.StoragePartitionAdjustmentTrigger
-
-
Field Summary
-
Fields inherited from class com.linkedin.davinci.store.AbstractStorageEngine
METADATA_PARTITION_ID
-
-
Constructor Summary
Constructors Constructor Description InMemoryStorageEngine(VeniceStoreVersionConfig storeDef)InMemoryStorageEngine(java.lang.String versionVersionName)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description InMemoryStoragePartitioncreateStoragePartition(StoragePartitionConfig storagePartitionConfig)java.util.Set<java.lang.Integer>getPersistedPartitionIds()longgetStoreSizeInBytes()PersistenceTypegetType()-
Methods inherited from class com.linkedin.davinci.store.AbstractStorageEngine
addStoragePartition, addStoragePartition, adjustStoragePartition, beginBatchWrite, checkDatabaseIntegrity, clearPartitionOffset, clearStoreVersionState, close, closeMetadataPartition, closePartition, containsPartition, createSnapshot, delete, deleteWithReplicationMetadata, drop, dropMetadataPartition, dropPartition, endBatchWrite, get, get, get, getByKeyPrefix, getCachedRMDSizeInBytes, getCachedStoreSizeInBytes, getCompressionStrategy, getIterator, getMetadataPartition, getNumberOfPartitions, getPartitionIds, getPartitionOffset, getPartitionOrThrow, getPartitionSizeInBytes, getReplicationMetadata, getRMDSizeInBytes, getRWLockForPartitionOrThrow, getStoreVersionName, getStoreVersionState, hasMemorySpaceLeft, isChunked, isClosed, isMetadataPartition, put, put, put, putPartitionOffset, putReplicationMetadata, putStoreVersionState, putWithReplicationMetadata, reopenStoragePartition, restoreStoragePartitions, restoreStoragePartitions, suppressLogs, sync, toString, updateStoreVersionStateCache
-
-
-
-
Constructor Detail
-
InMemoryStorageEngine
public InMemoryStorageEngine(VeniceStoreVersionConfig storeDef)
-
InMemoryStorageEngine
public InMemoryStorageEngine(java.lang.String versionVersionName)
-
-
Method Detail
-
getType
public PersistenceType getType()
- Specified by:
getTypein classAbstractStorageEngine<InMemoryStoragePartition>
-
getPersistedPartitionIds
public java.util.Set<java.lang.Integer> getPersistedPartitionIds()
- Specified by:
getPersistedPartitionIdsin classAbstractStorageEngine<InMemoryStoragePartition>
-
createStoragePartition
public InMemoryStoragePartition createStoragePartition(StoragePartitionConfig storagePartitionConfig)
- Specified by:
createStoragePartitionin classAbstractStorageEngine<InMemoryStoragePartition>
-
getStoreSizeInBytes
public long getStoreSizeInBytes()
- Specified by:
getStoreSizeInBytesin classAbstractStorageEngine<InMemoryStoragePartition>
-
-