com.hazelcast.cache.impl

Class CacheRecordStore

java.lang.Object

com.hazelcast.cache.impl.CacheRecordStore

All Implemented Interfaces:

ICacheRecordStore

public class CacheRecordStore
extends Object
implements ICacheRecordStore

Implementation of the ICacheRecordStore Represents a named ICache on-heap data for a single partition. Total data of an ICache object is the total CacheRecordStore on all partitions. This data structure is the actual cache operations implementation, data access, statistics, event firing etc. CacheRecordStore is managed by CachePartitionSegment.

See Also:

CachePartitionSegment

Method Summary

Methods

Modifier and Type	Method and Description
void	clear(Set<Data> keys, boolean isRemoveAll)
boolean	contains(Data key)
protected void	deleteAllCacheEntry(Set<Data> keys) modifies the keys
protected void	deleteCacheEntry(Data key)
void	destroy()
void	evictExpiredRecords()
Object	get(Data key, javax.cache.expiry.ExpiryPolicy expiryPolicy)
MapEntrySet	getAll(Set<Data> keySet, javax.cache.expiry.ExpiryPolicy expiryPolicy)
Object	getAndPut(Data key, Object value, javax.cache.expiry.ExpiryPolicy expiryPolicy, String caller)
protected Object	getAndPut(Data key, Object value, javax.cache.expiry.ExpiryPolicy expiryPolicy, String caller, boolean getValue)
protected Object	getAndPut(Data key, Object value, javax.cache.expiry.ExpiryPolicy expiryPolicy, String caller, boolean getValue, boolean disableWriteThrough)
Object	getAndRemove(Data key, String caller)
Object	getAndReplace(Data key, Object value, javax.cache.expiry.ExpiryPolicy expiryPolicy, String caller)
CacheStatisticsImpl	getCacheStats()
CacheConfig	getConfig()
String	getName()
Map<Data,CacheRecord>	getReadOnlyRecords()
CacheRecord	getRecord(Data key)
Object	invoke(Data key, javax.cache.processor.EntryProcessor entryProcessor, Object[] arguments)
CacheKeyIteratorResult	iterator(int tableIndex, int size)
Set<Data>	loadAll(Set<Data> keys, boolean replaceExistingValues)
protected Map<Data,Object>	loadAllCacheEntry(Set<Data> keys)
void	onDestroy()
protected boolean	processExpiredEntry(Data key, CacheRecord record, long now)
protected boolean	processExpiredEntry(Data key, CacheRecord record, long expiryTime, long now)
void	publishCompletedEvent(String cacheName, int completionId, Data dataKey, int orderKey)
protected void	publishEvent(String cacheName, CacheEventType eventType, Data dataKey, Data dataOldValue, Data dataValue, boolean isOldValueAvailable)
void	put(Data key, Object value, javax.cache.expiry.ExpiryPolicy expiryPolicy, String caller)
boolean	putIfAbsent(Data key, Object value, javax.cache.expiry.ExpiryPolicy expiryPolicy, String caller)
protected boolean	putIfAbsent(Data key, Object value, javax.cache.expiry.ExpiryPolicy expiryPolicy, String caller, boolean disableWriteThrough)
protected Object	readThroughCache(Data key)
boolean	remove(Data key, Object value, String caller)
boolean	remove(Data key, String caller)
CacheRecord	removeRecord(Data key)
boolean	replace(Data key, Object value, javax.cache.expiry.ExpiryPolicy expiryPolicy, String caller)
boolean	replace(Data key, Object oldValue, Object newValue, javax.cache.expiry.ExpiryPolicy expiryPolicy, String caller)
void	setRecord(Data key, CacheRecord record)
int	size()
protected void	writeThroughCache(Data key, Object value)

Methods inherited from class java.lang.Object

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

Method Detail

get

public Object get(Data key,
         javax.cache.expiry.ExpiryPolicy expiryPolicy)

Specified by:

get in interface ICacheRecordStore

put

public void put(Data key,
       Object value,
       javax.cache.expiry.ExpiryPolicy expiryPolicy,
       String caller)

Specified by:

put in interface ICacheRecordStore

getAndPut

protected Object getAndPut(Data key,
               Object value,
               javax.cache.expiry.ExpiryPolicy expiryPolicy,
               String caller,
               boolean getValue,
               boolean disableWriteThrough)

getAndPut

protected Object getAndPut(Data key,
               Object value,
               javax.cache.expiry.ExpiryPolicy expiryPolicy,
               String caller,
               boolean getValue)

getAndPut

public Object getAndPut(Data key,
               Object value,
               javax.cache.expiry.ExpiryPolicy expiryPolicy,
               String caller)

Specified by:

getAndPut in interface ICacheRecordStore

putIfAbsent

public boolean putIfAbsent(Data key,
                  Object value,
                  javax.cache.expiry.ExpiryPolicy expiryPolicy,
                  String caller)

Specified by:

putIfAbsent in interface ICacheRecordStore

putIfAbsent

protected boolean putIfAbsent(Data key,
                  Object value,
                  javax.cache.expiry.ExpiryPolicy expiryPolicy,
                  String caller,
                  boolean disableWriteThrough)

getAndRemove

public Object getAndRemove(Data key,
                  String caller)

Specified by:

getAndRemove in interface ICacheRecordStore

remove

public boolean remove(Data key,
             String caller)

Specified by:

remove in interface ICacheRecordStore

remove

public boolean remove(Data key,
             Object value,
             String caller)

Specified by:

remove in interface ICacheRecordStore

replace

public boolean replace(Data key,
              Object value,
              javax.cache.expiry.ExpiryPolicy expiryPolicy,
              String caller)

Specified by:

replace in interface ICacheRecordStore

replace

public boolean replace(Data key,
              Object oldValue,
              Object newValue,
              javax.cache.expiry.ExpiryPolicy expiryPolicy,
              String caller)

Specified by:

replace in interface ICacheRecordStore

getAndReplace

public Object getAndReplace(Data key,
                   Object value,
                   javax.cache.expiry.ExpiryPolicy expiryPolicy,
                   String caller)

Specified by:

getAndReplace in interface ICacheRecordStore

contains

public boolean contains(Data key)

Specified by:

contains in interface ICacheRecordStore

getAll

public MapEntrySet getAll(Set<Data> keySet,
                 javax.cache.expiry.ExpiryPolicy expiryPolicy)

Specified by:

getAll in interface ICacheRecordStore

size

public int size()

Specified by:

size in interface ICacheRecordStore

clear

public void clear(Set<Data> keys,
         boolean isRemoveAll)

Specified by:

clear in interface ICacheRecordStore

destroy

public void destroy()

Specified by:

destroy in interface ICacheRecordStore

onDestroy

public void onDestroy()

getRecord

public CacheRecord getRecord(Data key)

Specified by:

getRecord in interface ICacheRecordStore

setRecord

public void setRecord(Data key,
             CacheRecord record)

Specified by:

setRecord in interface ICacheRecordStore

removeRecord

public CacheRecord removeRecord(Data key)

Specified by:

removeRecord in interface ICacheRecordStore

iterator

public CacheKeyIteratorResult iterator(int tableIndex,
                              int size)

Specified by:

iterator in interface ICacheRecordStore

invoke

public Object invoke(Data key,
            javax.cache.processor.EntryProcessor entryProcessor,
            Object[] arguments)

Specified by:

invoke in interface ICacheRecordStore

loadAll

public Set<Data> loadAll(Set<Data> keys,
                boolean replaceExistingValues)

Specified by:

loadAll in interface ICacheRecordStore

getCacheStats

public CacheStatisticsImpl getCacheStats()

Specified by:

getCacheStats in interface ICacheRecordStore

getConfig

public CacheConfig getConfig()

Specified by:

getConfig in interface ICacheRecordStore

getName

public String getName()

Specified by:

getName in interface ICacheRecordStore

getReadOnlyRecords

public Map<Data,CacheRecord> getReadOnlyRecords()

Specified by:

getReadOnlyRecords in interface ICacheRecordStore

evictExpiredRecords

public void evictExpiredRecords()

readThroughCache

protected Object readThroughCache(Data key)
                           throws javax.cache.integration.CacheLoaderException

Throws:

javax.cache.integration.CacheLoaderException

writeThroughCache

protected void writeThroughCache(Data key,
                     Object value)
                          throws javax.cache.integration.CacheWriterException

Throws:

javax.cache.integration.CacheWriterException

deleteCacheEntry

protected void deleteCacheEntry(Data key)

deleteAllCacheEntry

protected void deleteAllCacheEntry(Set<Data> keys)

modifies the keys

Parameters:

keys - : keys to delete, after method returns it includes only deleted keys

loadAllCacheEntry

protected Map<Data,Object> loadAllCacheEntry(Set<Data> keys)

processExpiredEntry

protected boolean processExpiredEntry(Data key,
                          CacheRecord record,
                          long now)

processExpiredEntry

protected boolean processExpiredEntry(Data key,
                          CacheRecord record,
                          long expiryTime,
                          long now)

publishCompletedEvent

public void publishCompletedEvent(String cacheName,
                         int completionId,
                         Data dataKey,
                         int orderKey)

Specified by:

publishCompletedEvent in interface ICacheRecordStore

publishEvent

protected void publishEvent(String cacheName,
                CacheEventType eventType,
                Data dataKey,
                Data dataOldValue,
                Data dataValue,
                boolean isOldValueAvailable)