Package com.linkedin.davinci.store.memory

Class InMemoryStorageEngine

java.lang.Object

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

com.linkedin.davinci.store.memory.InMemoryStorageEngine

All Implemented Interfaces:

Closeable, 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(String versionVersionName)

Method Summary

Modifier and Type	Method	Description
InMemoryStoragePartition	createStoragePartition(StoragePartitionConfig storagePartitionConfig)
Set<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

Methods inherited from class java.lang.Object

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

Constructor Details

InMemoryStorageEngine

public InMemoryStorageEngine(VeniceStoreVersionConfig storeDef)

InMemoryStorageEngine

public InMemoryStorageEngine(String versionVersionName)

Method Details

getType

public PersistenceType getType()

Specified by:

getType in class AbstractStorageEngine<InMemoryStoragePartition>

getPersistedPartitionIds

public Set<Integer> getPersistedPartitionIds()

Specified by:

getPersistedPartitionIds in class AbstractStorageEngine<InMemoryStoragePartition>

createStoragePartition

public InMemoryStoragePartition createStoragePartition(StoragePartitionConfig storagePartitionConfig)

Specified by:

createStoragePartition in class AbstractStorageEngine<InMemoryStoragePartition>

getStoreSizeInBytes

public long getStoreSizeInBytes()

Specified by:

getStoreSizeInBytes in class AbstractStorageEngine<InMemoryStoragePartition>