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 InMemoryStoragePartition
createStoragePartition(StoragePartitionConfig storagePartitionConfig)
java.util.Set<java.lang.Integer>
getPersistedPartitionIds()
long
getStoreSizeInBytes()
PersistenceType
getType()
-
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:
getType
in classAbstractStorageEngine<InMemoryStoragePartition>
-
getPersistedPartitionIds
public java.util.Set<java.lang.Integer> getPersistedPartitionIds()
- Specified by:
getPersistedPartitionIds
in classAbstractStorageEngine<InMemoryStoragePartition>
-
createStoragePartition
public InMemoryStoragePartition createStoragePartition(StoragePartitionConfig storagePartitionConfig)
- Specified by:
createStoragePartition
in classAbstractStorageEngine<InMemoryStoragePartition>
-
getStoreSizeInBytes
public long getStoreSizeInBytes()
- Specified by:
getStoreSizeInBytes
in classAbstractStorageEngine<InMemoryStoragePartition>
-
-