Package com.linkedin.davinci.store.cache
Class VeniceStoreCacheStorageEngine
java.lang.Object
com.linkedin.davinci.store.AbstractStorageEngine<VeniceStoreCacheStoragePartition>
com.linkedin.davinci.store.cache.VeniceStoreCacheStorageEngine
- All Implemented Interfaces:
StorageEngine<VeniceStoreCacheStoragePartition>
,Closeable
,AutoCloseable
public class VeniceStoreCacheStorageEngine
extends AbstractStorageEngine<VeniceStoreCacheStoragePartition>
-
Field Summary
Fields inherited from class com.linkedin.davinci.store.AbstractStorageEngine
METADATA_PARTITION_ID
-
Constructor Summary
ConstructorsConstructorDescriptionVeniceStoreCacheStorageEngine
(String storeVersionName, ObjectCacheConfig config, org.apache.avro.Schema keySchema, com.github.benmanes.caffeine.cache.AsyncCacheLoader asyncCacheLoader) -
Method Summary
Modifier and TypeMethodDescriptioncreateStoragePartition
(StoragePartitionConfig partitionConfig) getCache()
getPartitionOrThrow
(int partitionId) getRWLockForPartitionOrThrow
(int partitionId) Making it public is for testing purpose.getType()
<K,
V> void putDeserializedValue
(K key, V value) Methods inherited from class com.linkedin.davinci.store.AbstractStorageEngine
addStoragePartition, adjustStoragePartition, beginBatchWrite, checkDatabaseIntegrity, clearPartitionOffset, clearStoreVersionState, close, closeMetadataPartition, closePartition, containsPartition, delete, deleteWithReplicationMetadata, drop, dropPartition, dropPartition, endBatchWrite, get, get, get, getByKeyPrefix, getIterator, getMetadataPartition, getNumberOfPartitions, getPartitionIds, getPartitionOffset, getPartitions, getReplicationMetadata, 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
Methods inherited from interface com.linkedin.davinci.store.StorageEngine
getStats
-
Constructor Details
-
VeniceStoreCacheStorageEngine
public VeniceStoreCacheStorageEngine(String storeVersionName, ObjectCacheConfig config, org.apache.avro.Schema keySchema, com.github.benmanes.caffeine.cache.AsyncCacheLoader asyncCacheLoader)
-
-
Method Details
-
getType
-
getPersistedPartitionIds
-
createStoragePartition
public VeniceStoreCacheStoragePartition createStoragePartition(StoragePartitionConfig partitionConfig) - Specified by:
createStoragePartition
in classAbstractStorageEngine<VeniceStoreCacheStoragePartition>
-
getPartitionOrThrow
- Specified by:
getPartitionOrThrow
in interfaceStorageEngine<VeniceStoreCacheStoragePartition>
- Overrides:
getPartitionOrThrow
in classAbstractStorageEngine<VeniceStoreCacheStoragePartition>
-
getRWLockForPartitionOrThrow
Description copied from class:AbstractStorageEngine
Making it public is for testing purpose.- Overrides:
getRWLockForPartitionOrThrow
in classAbstractStorageEngine<VeniceStoreCacheStoragePartition>
-
putDeserializedValue
public <K,V> void putDeserializedValue(K key, V value) -
getCache
-