public class CacheRecordStore extends AbstractCacheRecordStore<CacheRecord,CacheRecordHashMap>
ICacheRecordStore
Hazelcast splits data homogeneously to partitions using keys. CacheRecordStore represents a named ICache on-heap
data store for a single partition.
This data structure is responsible for CRUD operations, entry processing, statistics, publishing events, cache
loader and writer and internal data operations like backup.
CacheRecordStore is accessed through CachePartitionSegment and CacheService.
CacheRecordStore is managed by CachePartitionSegment.Sample code accessing a CacheRecordStore and getting a value. Typical operation implementation:
CacheService service = getService();
ICacheRecordStore cache = service.getOrCreateCache(name, partitionId);
cache.get(key, expiryPolicy);
See AbstractCacheOperation subclasses for actual examples.
CachePartitionSegment,
CacheService,
AbstractCacheOperationAbstractCacheRecordStore.MaxSizeEvictionChecker| Modifier and Type | Field and Description |
|---|---|
protected CacheRecordFactory |
cacheRecordFactory |
protected SerializationService |
serializationService |
batchEvent, cacheConfig, cacheLoader, cacheService, cacheWriter, DEFAULT_INITIAL_CAPACITY, defaultExpiryPolicy, evictionChecker, evictionConfig, evictionPolicyEvaluator, evictionStrategy, hasExpiringEntry, isEventBatchingEnabled, isEventsEnabled, maxSizeChecker, name, nodeEngine, partitionCount, partitionId, records, statisticsONE_HUNDRED_PERCENT| Constructor and Description |
|---|
CacheRecordStore(String name,
int partitionId,
NodeEngine nodeEngine,
AbstractCacheService cacheService) |
| Modifier and Type | Method and Description |
|---|---|
protected CacheEntryProcessorEntry |
createCacheEntryProcessorEntry(Data key,
CacheRecord record,
long now,
int completionId) |
protected CacheMaxSizeChecker |
createCacheMaxSizeChecker(int size,
CacheEvictionConfig.CacheMaxSizePolicy maxSizePolicy) |
protected CacheRecordFactory |
createCacheRecordFactory() |
protected <T> CacheRecord |
createRecord(T value,
long creationTime,
long expiryTime) |
protected CacheRecordHashMap |
createRecordCacheMap() |
protected CacheRecord |
dataToRecord(Data data) |
protected <T> T |
dataToValue(Data data) |
protected Data |
recordToData(CacheRecord record) |
protected <T> T |
recordToValue(CacheRecord record) |
protected Data |
toHeapData(Object obj) |
protected <T> Data |
valueToData(T value) |
protected <T> CacheRecord |
valueToRecord(T value) |
accessRecord, clear, closeListeners, closeResources, compare, contains, createEvictionChecker, createRecord, createRecord, createRecord, createRecordWithExpiry, creatEvictionPolicyEvaluator, creatEvictionStrategy, deleteAllCacheEntry, deleteCacheEntry, deleteRecord, destroy, evictIfRequired, expiryPolicyToTTL, get, getAll, getAndPut, getAndRemove, getAndReplace, getCacheStats, getConfig, getExpiryPolicy, getName, getReadOnlyRecords, getRecord, invoke, isEvictionEnabled, isEvictionRequired, isReadThrough, isStatisticsEnabled, isWriteThrough, iterator, loadAll, loadAllCacheEntry, onDeleteRecord, onDeleteRecordError, onGet, onGetError, onPut, onPutError, onPutIfAbsent, onPutIfAbsentError, onRecordAccess, onRemove, onRemoveError, onReplace, onReplaceError, onUpdateRecord, onUpdateRecordError, processExpiredEntry, processExpiredEntry, publishBatchedEvents, publishEvent, put, put, put, putIfAbsent, putIfAbsent, putRecord, readThroughCache, readThroughRecord, remove, remove, removeAll, removeRecord, replace, replace, setRecord, size, toData, toEventData, toRecord, toValue, ttlToExpirePolicy, updateAccessDuration, updateGetAndPutStat, updateHasExpiringEntry, updateRecord, updateRecordWithExpiry, updateReplaceStat, writeThroughCacheprotected SerializationService serializationService
protected CacheRecordFactory cacheRecordFactory
public CacheRecordStore(String name, int partitionId, NodeEngine nodeEngine, AbstractCacheService cacheService)
protected CacheMaxSizeChecker createCacheMaxSizeChecker(int size, CacheEvictionConfig.CacheMaxSizePolicy maxSizePolicy)
createCacheMaxSizeChecker in class AbstractCacheRecordStore<CacheRecord,CacheRecordHashMap>protected CacheRecordHashMap createRecordCacheMap()
createRecordCacheMap in class AbstractCacheRecordStore<CacheRecord,CacheRecordHashMap>protected CacheEntryProcessorEntry createCacheEntryProcessorEntry(Data key, CacheRecord record, long now, int completionId)
createCacheEntryProcessorEntry in class AbstractCacheRecordStore<CacheRecord,CacheRecordHashMap>protected CacheRecordFactory createCacheRecordFactory()
protected <T> CacheRecord createRecord(T value, long creationTime, long expiryTime)
createRecord in class AbstractCacheRecordStore<CacheRecord,CacheRecordHashMap>protected <T> Data valueToData(T value)
valueToData in class AbstractCacheRecordStore<CacheRecord,CacheRecordHashMap>protected <T> T dataToValue(Data data)
dataToValue in class AbstractCacheRecordStore<CacheRecord,CacheRecordHashMap>protected <T> CacheRecord valueToRecord(T value)
valueToRecord in class AbstractCacheRecordStore<CacheRecord,CacheRecordHashMap>protected <T> T recordToValue(CacheRecord record)
recordToValue in class AbstractCacheRecordStore<CacheRecord,CacheRecordHashMap>protected Data recordToData(CacheRecord record)
recordToData in class AbstractCacheRecordStore<CacheRecord,CacheRecordHashMap>protected CacheRecord dataToRecord(Data data)
dataToRecord in class AbstractCacheRecordStore<CacheRecord,CacheRecordHashMap>protected Data toHeapData(Object obj)
toHeapData in class AbstractCacheRecordStore<CacheRecord,CacheRecordHashMap>Copyright © 2014 Hazelcast, Inc.. All Rights Reserved.