com.hazelcast.cache.hotrestart

Class HotRestartEnterpriseCacheRecordStore

java.lang.Object

com.hazelcast.cache.impl.AbstractCacheRecordStore<com.hazelcast.cache.impl.record.CacheRecord,com.hazelcast.cache.impl.record.CacheRecordHashMap>

com.hazelcast.cache.impl.CacheRecordStore

com.hazelcast.cache.hotrestart.HotRestartEnterpriseCacheRecordStore

All Implemented Interfaces:

com.hazelcast.cache.impl.ICacheRecordStore, com.hazelcast.internal.eviction.EvictionListener<com.hazelcast.nio.serialization.Data,com.hazelcast.cache.impl.record.CacheRecord>, com.hazelcast.spi.hotrestart.RamStore

public class HotRestartEnterpriseCacheRecordStore
extends com.hazelcast.cache.impl.CacheRecordStore
implements com.hazelcast.spi.hotrestart.RamStore

On-heap cache record store with Hot Restart support.

Field Summary

Fields inherited from class com.hazelcast.cache.impl.CacheRecordStore

serializationService

Fields inherited from class com.hazelcast.cache.impl.AbstractCacheRecordStore

batchEvent, cacheConfig, cacheContext, cacheLoader, cacheRecordFactory, cacheService, cacheWriter, clearExpiredRecordsTask, DEFAULT_INITIAL_CAPACITY, defaultExpiryPolicy, disablePerEntryInvalidationEvents, eventJournalConfig, eventsBatchingEnabled, eventsEnabled, evictionChecker, evictionConfig, evictionPolicyEvaluator, evictionStrategy, expirationIterator, expiredKeys, hasEntryWithExpiration, name, nodeEngine, objectNamespace, partitionCount, partitionId, persistWanReplicatedData, primary, records, SOURCE_NOT_AVAILABLE, ss, statistics, valueComparator, wanReplicationEnabled

Fields inherited from interface com.hazelcast.internal.eviction.EvictionListener

NO_LISTENER

Constructor Summary

Constructors

Constructor and Description
HotRestartEnterpriseCacheRecordStore(String name, int partitionId, com.hazelcast.spi.NodeEngine nodeEngine, EnterpriseCacheService cacheService, boolean fsync, long keyPrefix)

Method Summary

Modifier and Type	Method and Description
void	accept(com.hazelcast.spi.hotrestart.KeyHandle kh, byte[] valueBytes)
void	close(boolean onShutdown)
boolean	copyEntry(com.hazelcast.spi.hotrestart.KeyHandle kh, int expectedSize, com.hazelcast.spi.hotrestart.RecordDataSink sink)
protected com.hazelcast.cache.impl.record.CacheRecord	doPutRecord(com.hazelcast.nio.serialization.Data key, com.hazelcast.cache.impl.record.CacheRecord record, String source, boolean updateJournal)
void	onEvict(com.hazelcast.nio.serialization.Data key, com.hazelcast.cache.impl.record.CacheRecord record, boolean wasExpired)
protected void	onProcessExpiredEntry(com.hazelcast.nio.serialization.Data key, com.hazelcast.cache.impl.record.CacheRecord record, long expiryTime, long now, String source, String origin)
protected void	onRemove(com.hazelcast.nio.serialization.Data key, Object value, String source, boolean getValue, com.hazelcast.cache.impl.record.CacheRecord record, boolean removed)
protected void	onUpdateRecord(com.hazelcast.nio.serialization.Data key, com.hazelcast.cache.impl.record.CacheRecord record, Object value, com.hazelcast.nio.serialization.Data oldDataValue)
void	removeNullEntries(com.hazelcast.spi.hotrestart.impl.SetOfKeyHandle keyHandles)
com.hazelcast.cache.impl.record.CacheRecord	removeRecord(com.hazelcast.nio.serialization.Data key)
void	reset()
com.hazelcast.spi.hotrestart.impl.KeyOnHeap	toKeyHandle(byte[] key)

Methods inherited from class com.hazelcast.cache.impl.CacheRecordStore

createCacheEntryProcessorEntry, createCacheEvictionChecker, createRecord, createRecordCacheMap, dataToValue, disposeDeferredBlocks, recordToData, recordToValue, toHeapData, valueToData

Methods inherited from class com.hazelcast.cache.impl.AbstractCacheRecordStore

accessRecord, accumulateOrSendExpiredKeysToBackup, clear, closeListeners, compare, contains, createEvictionPolicyEvaluator, createEvictionStrategy, createRecord, createRecord, createRecord, createRecord, createRecordWithExpiry, createRecordWithExpiry, createRecordWithExpiry, createRecordWithExpiry, deleteAllCacheEntry, deleteCacheEntry, deleteCacheEntry, deleteRecord, deleteRecord, deleteRecord, destroy, destroyEventJournal, destroyInternals, doRemoveRecord, evictExpiredEntries, evictIfExpired, evictIfRequired, extractExpiryPolicyOfRecord, fetchEntries, fetchKeys, forceRemoveRecord, get, getAll, getAndPut, getAndRemove, getAndRemove, getAndReplace, getCacheStats, getConfig, getExpiredKeysQueue, getExpiryPolicy, getExpiryPolicy, getName, getObjectNamespace, getPartitionId, getReadOnlyRecords, getRecord, getValueComparatorOf, init, initExpirationIterator, instrument, invalidateEntry, invalidateEntry, invoke, isEventsEnabled, isEvictionEnabled, isExpirable, isInvalidationEnabled, isReadThrough, isStatisticsEnabled, isWanReplicationEnabled, isWriteThrough, loadAll, loadAllCacheEntry, markExpirable, merge, merge, onCreateRecordError, onDeleteRecord, onDestroy, onGet, onGetError, onPut, onPutError, onPutIfAbsent, onPutIfAbsentError, onRecordAccess, onRemoveError, onReplace, onReplaceError, onUpdateExpiryPolicy, onUpdateExpiryPolicyError, onUpdateRecordError, processExpiredEntry, processExpiredEntry, processExpiredEntry, processExpiredEntry, processExpiredEntry, publishBatchedEvents, publishEvent, put, put, put, putIfAbsent, putIfAbsent, putRecord, readThroughCache, readThroughRecord, remove, remove, remove, removeAll, replace, replace, sampleAndForceRemoveEntries, setExpiryPolicy, size, toData, toEventData, toStorageValue, toValue, updateAccessDuration, updateExpiryPolicyOfRecord, updateGetAndPutStat, updateRecord, updateRecord, updateRecordValue, updateRecordWithExpiry, updateRecordWithExpiry, updateRecordWithExpiry, updateRecordWithExpiry, updateRecordWithExpiry, updateRecordWithExpiry, updateRecordWithExpiry, updateReplaceStat, writeThroughCache

Methods inherited from class java.lang.Object

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

Constructor Detail

HotRestartEnterpriseCacheRecordStore

public HotRestartEnterpriseCacheRecordStore(String name,
                                            int partitionId,
                                            com.hazelcast.spi.NodeEngine nodeEngine,
                                            EnterpriseCacheService cacheService,
                                            boolean fsync,
                                            long keyPrefix)

Method Detail

doPutRecord

protected com.hazelcast.cache.impl.record.CacheRecord doPutRecord(com.hazelcast.nio.serialization.Data key,
                                                                  com.hazelcast.cache.impl.record.CacheRecord record,
                                                                  String source,
                                                                  boolean updateJournal)

Overrides:

doPutRecord in class com.hazelcast.cache.impl.AbstractCacheRecordStore<com.hazelcast.cache.impl.record.CacheRecord,com.hazelcast.cache.impl.record.CacheRecordHashMap>

onUpdateRecord

protected void onUpdateRecord(com.hazelcast.nio.serialization.Data key,
                              com.hazelcast.cache.impl.record.CacheRecord record,
                              Object value,
                              com.hazelcast.nio.serialization.Data oldDataValue)

Overrides:

onUpdateRecord in class com.hazelcast.cache.impl.AbstractCacheRecordStore<com.hazelcast.cache.impl.record.CacheRecord,com.hazelcast.cache.impl.record.CacheRecordHashMap>

onRemove

protected void onRemove(com.hazelcast.nio.serialization.Data key,
                        Object value,
                        String source,
                        boolean getValue,
                        com.hazelcast.cache.impl.record.CacheRecord record,
                        boolean removed)

Overrides:

onRemove in class com.hazelcast.cache.impl.AbstractCacheRecordStore<com.hazelcast.cache.impl.record.CacheRecord,com.hazelcast.cache.impl.record.CacheRecordHashMap>

removeRecord

public com.hazelcast.cache.impl.record.CacheRecord removeRecord(com.hazelcast.nio.serialization.Data key)

Specified by:

removeRecord in interface com.hazelcast.cache.impl.ICacheRecordStore

Overrides:

removeRecord in class com.hazelcast.cache.impl.AbstractCacheRecordStore<com.hazelcast.cache.impl.record.CacheRecord,com.hazelcast.cache.impl.record.CacheRecordHashMap>

onEvict

public void onEvict(com.hazelcast.nio.serialization.Data key,
                    com.hazelcast.cache.impl.record.CacheRecord record,
                    boolean wasExpired)

Specified by:

onEvict in interface com.hazelcast.internal.eviction.EvictionListener<com.hazelcast.nio.serialization.Data,com.hazelcast.cache.impl.record.CacheRecord>

Overrides:

onEvict in class com.hazelcast.cache.impl.AbstractCacheRecordStore<com.hazelcast.cache.impl.record.CacheRecord,com.hazelcast.cache.impl.record.CacheRecordHashMap>

onProcessExpiredEntry

protected void onProcessExpiredEntry(com.hazelcast.nio.serialization.Data key,
                                     com.hazelcast.cache.impl.record.CacheRecord record,
                                     long expiryTime,
                                     long now,
                                     String source,
                                     String origin)

Overrides:

onProcessExpiredEntry in class com.hazelcast.cache.impl.AbstractCacheRecordStore<com.hazelcast.cache.impl.record.CacheRecord,com.hazelcast.cache.impl.record.CacheRecordHashMap>

copyEntry

public boolean copyEntry(com.hazelcast.spi.hotrestart.KeyHandle kh,
                         int expectedSize,
                         com.hazelcast.spi.hotrestart.RecordDataSink sink)

Specified by:

copyEntry in interface com.hazelcast.spi.hotrestart.RamStore

toKeyHandle

public com.hazelcast.spi.hotrestart.impl.KeyOnHeap toKeyHandle(byte[] key)

Specified by:

toKeyHandle in interface com.hazelcast.spi.hotrestart.RamStore

accept

public void accept(com.hazelcast.spi.hotrestart.KeyHandle kh,
                   byte[] valueBytes)

Specified by:

accept in interface com.hazelcast.spi.hotrestart.RamStore

removeNullEntries

public void removeNullEntries(com.hazelcast.spi.hotrestart.impl.SetOfKeyHandle keyHandles)

Specified by:

removeNullEntries in interface com.hazelcast.spi.hotrestart.RamStore

reset

public void reset()

Specified by:

reset in interface com.hazelcast.cache.impl.ICacheRecordStore

Overrides:

reset in class com.hazelcast.cache.impl.AbstractCacheRecordStore<com.hazelcast.cache.impl.record.CacheRecord,com.hazelcast.cache.impl.record.CacheRecordHashMap>

close

public void close(boolean onShutdown)

Specified by:

close in interface com.hazelcast.cache.impl.ICacheRecordStore

Overrides:

close in class com.hazelcast.cache.impl.AbstractCacheRecordStore<com.hazelcast.cache.impl.record.CacheRecord,com.hazelcast.cache.impl.record.CacheRecordHashMap>