com.hazelcast.internal.nearcache.impl.store

Class AbstractNearCacheRecordStore<K,V,KS,R extends NearCacheRecord,NCRM extends SampleableNearCacheRecordMap<KS,R>>

java.lang.Object

com.hazelcast.internal.nearcache.impl.store.AbstractNearCacheRecordStore<K,V,KS,R,NCRM>

Type Parameters:

K - the type of the key stored in Near Cache

V - the type of the value stored in Near Cache

KS - the type of the key of the underlying NearCacheRecordMap

R - the type of the value of the underlying NearCacheRecordMap

NCRM - the type of the underlying NearCacheRecordMap

All Implemented Interfaces:

EvictionListener<KS,R>, NearCacheRecordStore<K,V>, InitializingObject

Direct Known Subclasses:

BaseHeapNearCacheRecordStore

public abstract class AbstractNearCacheRecordStore<K,V,KS,R extends NearCacheRecord,NCRM extends SampleableNearCacheRecordMap<KS,R>>
extends Object
implements NearCacheRecordStore<K,V>, EvictionListener<KS,R>

Abstract implementation of NearCacheRecordStore and EvictionListener.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	AbstractNearCacheRecordStore.ReserveForUpdateFunction

Field Summary

Fields

Modifier and Type	Field and Description
protected ClassLoader	classLoader
protected EvictionChecker	evictionChecker
protected boolean	evictionDisabled
protected EvictionPolicyEvaluator<KS,R>	evictionPolicyEvaluator
protected SamplingEvictionStrategy<KS,R,NCRM>	evictionStrategy
protected long	maxIdleMillis
protected static long	MILLI_SECONDS_IN_A_SECOND
protected NearCacheConfig	nearCacheConfig
protected NearCacheStatsImpl	nearCacheStats
protected NCRM	records
protected static long	REFERENCE_SIZE If Unsafe is available, Object array index scale (every index represents a reference) can be assumed as reference size.
protected static AtomicLongFieldUpdater<AbstractNearCacheRecordStore>	RESERVATION_ID
protected long	reservationId
protected SerializationService	serializationService
protected StaleReadDetector	staleReadDetector
protected long	timeToLiveMillis

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

NO_LISTENER

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractNearCacheRecordStore(NearCacheConfig nearCacheConfig, NearCacheStatsImpl nearCacheStats, SerializationService serializationService, ClassLoader classLoader)
	AbstractNearCacheRecordStore(NearCacheConfig nearCacheConfig, SerializationService serializationService, ClassLoader classLoader)

Method Summary

Modifier and Type	Method and Description
protected void	checkAvailable()
void	clear() Removes all stored values.
protected abstract boolean	containsRecordKey(K key)
protected abstract EvictionChecker	createNearCacheEvictionChecker(EvictionConfig evictionConfig, NearCacheConfig nearCacheConfig)
protected abstract NCRM	createNearCacheRecordMap(NearCacheConfig nearCacheConfig)
protected V	dataToValue(Data data)
void	destroy() Clears the record store and destroys it.
void	doEviction() Does eviction as specified configuration EvictionConfig in NearCacheConfig regardless from the max-size policy.
void	doEvictionIfRequired() Does eviction as specified configuration EvictionConfig in NearCacheConfig.
V	get(K key) Gets the value associated with the given key.
protected abstract long	getKeyStorageMemoryCost(K key)
NearCacheStats	getNearCacheStats() Get the NearCacheStats instance to monitor this record store.
protected abstract R	getOrCreateToReserve(K key, Data keyData)
abstract R	getRecord(K key) Gets the record associated with the given key.
protected abstract long	getRecordStorageMemoryCost(R record)
StaleReadDetector	getStaleReadDetector()
protected long	getTotalStorageMemoryCost(K key, R record)
void	initialize()
protected boolean	isAvailable()
protected boolean	isRecordExpired(R record)
void	onEvict(KS key, R record, boolean wasExpired) Called when an Evictable entry is evicted.
protected void	onExpire(K key, R record)
protected void	onGet(K key, V value, R record)
protected void	onGetError(K key, V value, R record, Throwable error)
protected void	onPut(K key, V value, R record, R oldRecord)
protected void	onPutError(K key, V value, R record, R oldRecord, Throwable error)
protected void	onRecordCreate(K key, Data keyData, R record)
protected void	onRemove(K key, R record, boolean removed)
protected void	onRemoveError(K key, R record, boolean removed, Throwable error)
void	put(K key, Data keyData, V value) Puts (associates) a value with the given key.
protected abstract R	putRecord(K key, R record)
protected abstract V	recordToValue(R record)
boolean	remove(K key) Removes the value associated with the given key.
protected abstract R	removeRecord(K key)
void	setStaleReadDetector(StaleReadDetector staleReadDetector)
int	size() Gets the number of stored records.
protected Data	toData(Object obj)
protected V	toValue(Object obj)
V	tryPublishReserved(K key, V value, long reservationId, boolean deserialize)
long	tryReserveForUpdate(K key, Data keyData)
protected abstract V	updateAndGetReserved(K key, V value, long reservationId, boolean deserialize)
protected abstract void	updateRecordValue(R record, V value)
protected R	updateReservedRecordInternal(K key, V value, R reservedRecord, long reservationId)
protected Data	valueToData(V value)
protected abstract R	valueToRecord(V value)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.internal.nearcache.NearCacheRecordStore

doExpiration, loadKeys, selectToSave, storeKeys

Field Detail

RESERVATION_ID

protected static final AtomicLongFieldUpdater<AbstractNearCacheRecordStore> RESERVATION_ID

REFERENCE_SIZE

protected static final long REFERENCE_SIZE

If Unsafe is available, Object array index scale (every index represents a reference) can be assumed as reference size.

Otherwise, we assume reference size as integer size that means we assume 32 bit JVM or compressed-references enabled 64 bit JVM by ignoring compressed-references disable mode on 64 bit JVM.

MILLI_SECONDS_IN_A_SECOND

protected static final long MILLI_SECONDS_IN_A_SECOND

See Also:

Constant Field Values

timeToLiveMillis

protected final long timeToLiveMillis

maxIdleMillis

protected final long maxIdleMillis

nearCacheConfig

protected final NearCacheConfig nearCacheConfig

serializationService

protected final SerializationService serializationService

classLoader

protected final ClassLoader classLoader

nearCacheStats

protected final NearCacheStatsImpl nearCacheStats

evictionDisabled

protected final boolean evictionDisabled

evictionChecker

protected EvictionChecker evictionChecker

evictionStrategy

protected SamplingEvictionStrategy<KS,R extends NearCacheRecord,NCRM extends SampleableNearCacheRecordMap<KS,R>> evictionStrategy

evictionPolicyEvaluator

protected EvictionPolicyEvaluator<KS,R extends NearCacheRecord> evictionPolicyEvaluator

records

protected NCRM extends SampleableNearCacheRecordMap<KS,R> records

staleReadDetector

protected volatile StaleReadDetector staleReadDetector

reservationId

protected volatile long reservationId

Constructor Detail

AbstractNearCacheRecordStore

public AbstractNearCacheRecordStore(NearCacheConfig nearCacheConfig,
                                    SerializationService serializationService,
                                    ClassLoader classLoader)

AbstractNearCacheRecordStore

protected AbstractNearCacheRecordStore(NearCacheConfig nearCacheConfig,
                                       NearCacheStatsImpl nearCacheStats,
                                       SerializationService serializationService,
                                       ClassLoader classLoader)

Method Detail

initialize

public void initialize()

Specified by:

initialize in interface InitializingObject

setStaleReadDetector

public void setStaleReadDetector(StaleReadDetector staleReadDetector)

Specified by:

setStaleReadDetector in interface NearCacheRecordStore<K,V>

See Also:

StaleReadDetector

getStaleReadDetector

public StaleReadDetector getStaleReadDetector()

Specified by:

getStaleReadDetector in interface NearCacheRecordStore<K,V>

See Also:

StaleReadDetector

getRecord

public abstract R getRecord(K key)

Description copied from interface: NearCacheRecordStore

Gets the record associated with the given key.

Specified by:

getRecord in interface NearCacheRecordStore<K,V>

Parameters:

key - the key from which to get the associated NearCacheRecord.

Returns:

the NearCacheRecord associated with the given key.

createNearCacheEvictionChecker

protected abstract EvictionChecker createNearCacheEvictionChecker(EvictionConfig evictionConfig,
                                                                  NearCacheConfig nearCacheConfig)

createNearCacheRecordMap

protected abstract NCRM createNearCacheRecordMap(NearCacheConfig nearCacheConfig)

getKeyStorageMemoryCost

protected abstract long getKeyStorageMemoryCost(K key)

getRecordStorageMemoryCost

protected abstract long getRecordStorageMemoryCost(R record)

valueToRecord

protected abstract R valueToRecord(V value)

updateRecordValue

protected abstract void updateRecordValue(R record,
                                          V value)

recordToValue

protected abstract V recordToValue(R record)

getOrCreateToReserve

protected abstract R getOrCreateToReserve(K key,
                                          Data keyData)

updateAndGetReserved

protected abstract V updateAndGetReserved(K key,
                                          V value,
                                          long reservationId,
                                          boolean deserialize)

putRecord

protected abstract R putRecord(K key,
                               R record)

removeRecord

protected abstract R removeRecord(K key)

containsRecordKey

protected abstract boolean containsRecordKey(K key)

checkAvailable

protected void checkAvailable()

isAvailable

protected boolean isAvailable()

valueToData

protected Data valueToData(V value)

dataToValue

protected V dataToValue(Data data)

toData

protected Data toData(Object obj)

toValue

protected V toValue(Object obj)

getTotalStorageMemoryCost

protected long getTotalStorageMemoryCost(K key,
                                         R record)

isRecordExpired

protected boolean isRecordExpired(R record)

onGet

protected void onGet(K key,
                     V value,
                     R record)

onGetError

protected void onGetError(K key,
                          V value,
                          R record,
                          Throwable error)

onPut

protected void onPut(K key,
                     V value,
                     R record,
                     R oldRecord)

onPutError

protected void onPutError(K key,
                          V value,
                          R record,
                          R oldRecord,
                          Throwable error)

onRemove

protected void onRemove(K key,
                        R record,
                        boolean removed)

onRemoveError

protected void onRemoveError(K key,
                             R record,
                             boolean removed,
                             Throwable error)

onExpire

protected void onExpire(K key,
                        R record)

onEvict

public void onEvict(KS key,
                    R record,
                    boolean wasExpired)

Description copied from interface: EvictionListener

Called when an Evictable entry is evicted.

Specified by:

onEvict in interface EvictionListener<KS,R extends NearCacheRecord>

Parameters:

key - Accessor of the Evictable entry that is evicted.

record - Evictable entry that is evicted.

wasExpired - true if the entry was evicted due to expiration, false otherwise

get

public V get(K key)

Description copied from interface: NearCacheRecordStore

Gets the value associated with the given key.

Specified by:

get in interface NearCacheRecordStore<K,V>

Parameters:

key - the key from which to get the associated value.

Returns:

the value associated with the given key.

put

public void put(K key,
                Data keyData,
                V value)

Description copied from interface: NearCacheRecordStore

Puts (associates) a value with the given key.

Specified by:

put in interface NearCacheRecordStore<K,V>

Parameters:

key - the key to which the given value will be associated.

keyData - the key as Data to which the given value will be associated.

value - the value that will be associated with the key.

remove

public boolean remove(K key)

Description copied from interface: NearCacheRecordStore

Removes the value associated with the given key.

Specified by:

remove in interface NearCacheRecordStore<K,V>

Parameters:

key - the key from which the value will be removed.

Returns:

true if the value was removed, otherwise false.

clear

public void clear()

Description copied from interface: NearCacheRecordStore

Removes all stored values.

Specified by:

clear in interface NearCacheRecordStore<K,V>

destroy

public void destroy()

Description copied from interface: NearCacheRecordStore

Clears the record store and destroys it.

Specified by:

destroy in interface NearCacheRecordStore<K,V>

getNearCacheStats

public NearCacheStats getNearCacheStats()

Description copied from interface: NearCacheRecordStore

Get the NearCacheStats instance to monitor this record store.

Specified by:

getNearCacheStats in interface NearCacheRecordStore<K,V>

Returns:

the NearCacheStats instance to monitor this record store.

size

public int size()

Description copied from interface: NearCacheRecordStore

Gets the number of stored records.

Specified by:

size in interface NearCacheRecordStore<K,V>

Returns:

the number of stored records.

doEvictionIfRequired

public void doEvictionIfRequired()

Description copied from interface: NearCacheRecordStore

Does eviction as specified configuration EvictionConfig in NearCacheConfig.

Specified by:

doEvictionIfRequired in interface NearCacheRecordStore<K,V>

doEviction

public void doEviction()

Description copied from interface: NearCacheRecordStore

Does eviction as specified configuration EvictionConfig in NearCacheConfig regardless from the max-size policy.

Specified by:

doEviction in interface NearCacheRecordStore<K,V>

tryReserveForUpdate

public long tryReserveForUpdate(K key,
                                Data keyData)

Specified by:

tryReserveForUpdate in interface NearCacheRecordStore<K,V>

tryPublishReserved

public V tryPublishReserved(K key,
                            V value,
                            long reservationId,
                            boolean deserialize)

Specified by:

tryPublishReserved in interface NearCacheRecordStore<K,V>

onRecordCreate

protected void onRecordCreate(K key,
                              Data keyData,
                              R record)

updateReservedRecordInternal

protected R updateReservedRecordInternal(K key,
                                         V value,
                                         R reservedRecord,
                                         long reservationId)