com.hazelcast.map.impl.querycache.subscriber

Class QueryCacheRecordHashMap

java.lang.Object

java.util.AbstractMap<K,V>

com.hazelcast.util.ConcurrentReferenceHashMap<K,V>

com.hazelcast.util.SampleableConcurrentHashMap<Data,QueryCacheRecord>

com.hazelcast.map.impl.querycache.subscriber.QueryCacheRecordHashMap

All Implemented Interfaces:

EvictableStore<Data,QueryCacheRecord>, SampleableEvictableStore<Data,QueryCacheRecord>, IConcurrentMap<Data,QueryCacheRecord>, Serializable, ConcurrentMap<Data,QueryCacheRecord>, Map<Data,QueryCacheRecord>

public class QueryCacheRecordHashMap
extends SampleableConcurrentHashMap<Data,QueryCacheRecord>
implements SampleableEvictableStore<Data,QueryCacheRecord>

Evictable concurrent hash map implementation.

See Also:

SampleableConcurrentHashMap, SampleableEvictableStore, Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	QueryCacheRecordHashMap.QueryCacheEvictableSamplingEntry

Nested classes/interfaces inherited from class com.hazelcast.util.SampleableConcurrentHashMap

SampleableConcurrentHashMap.SamplingEntry<K,V>

Nested classes/interfaces inherited from class com.hazelcast.util.ConcurrentReferenceHashMap

ConcurrentReferenceHashMap.Option, ConcurrentReferenceHashMap.ReferenceType, ConcurrentReferenceHashMap.SimpleEntry<K,V>, ConcurrentReferenceHashMap.WriteThroughEntry

Nested classes/interfaces inherited from class java.util.AbstractMap

AbstractMap.SimpleImmutableEntry<K,V>

Nested classes/interfaces inherited from interface java.util.Map

Map.Entry<K,V>

Constructor Summary

Constructors

Constructor and Description
QueryCacheRecordHashMap(SerializationService serializationService, int initialCapacity)
QueryCacheRecordHashMap(SerializationService serializationService, int initialCapacity, float loadFactor, int concurrencyLevel, ConcurrentReferenceHashMap.ReferenceType keyType, ConcurrentReferenceHashMap.ReferenceType valueType, EnumSet<ConcurrentReferenceHashMap.Option> options)

Method Summary

Modifier and Type	Method and Description
protected QueryCacheRecordHashMap.QueryCacheEvictableSamplingEntry	createSamplingEntry(Data key, QueryCacheRecord value)
Iterable<QueryCacheRecordHashMap.QueryCacheEvictableSamplingEntry>	sample(int sampleCount) The sample method is used to sample a number of entries (defined by the samples parameter) from the internal data structure.
<C extends EvictionCandidate<Data,QueryCacheRecord>> boolean	tryEvict(C evictionCandidate, EvictionListener<Data,QueryCacheRecord> evictionListener) The evict method is called by the EvictionStrategy to eventually evict, by the policy, selected candidate from the internal data structures.

Methods inherited from class com.hazelcast.util.SampleableConcurrentHashMap

fetchEntries, fetchKeys, getRandomSamples, isValidForFetching, isValidForSampling

Methods inherited from class com.hazelcast.util.ConcurrentReferenceHashMap

applyIfAbsent, applyIfPresent, clear, contains, containsKey, containsValue, elements, entrySet, get, isEmpty, keys, keySet, purgeStaleEntries, put, putAll, putIfAbsent, remove, remove, replace, replace, size, values

Methods inherited from class java.util.AbstractMap

clone, equals, hashCode, toString

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.concurrent.ConcurrentMap

compute, computeIfAbsent, computeIfPresent, forEach, getOrDefault, merge, replaceAll

Methods inherited from interface java.util.Map

equals, hashCode

Constructor Detail

QueryCacheRecordHashMap

public QueryCacheRecordHashMap(SerializationService serializationService,
                               int initialCapacity)

QueryCacheRecordHashMap

public QueryCacheRecordHashMap(SerializationService serializationService,
                               int initialCapacity,
                               float loadFactor,
                               int concurrencyLevel,
                               ConcurrentReferenceHashMap.ReferenceType keyType,
                               ConcurrentReferenceHashMap.ReferenceType valueType,
                               EnumSet<ConcurrentReferenceHashMap.Option> options)

Method Detail

createSamplingEntry

protected QueryCacheRecordHashMap.QueryCacheEvictableSamplingEntry createSamplingEntry(Data key,
                                                                                       QueryCacheRecord value)

Overrides:

createSamplingEntry in class SampleableConcurrentHashMap<Data,QueryCacheRecord>

tryEvict

public <C extends EvictionCandidate<Data,QueryCacheRecord>> boolean tryEvict(C evictionCandidate,
                                                                             EvictionListener<Data,QueryCacheRecord> evictionListener)

Description copied from interface: EvictableStore

The evict method is called by the EvictionStrategy to eventually evict, by the policy, selected candidate from the internal data structures. It could be the selected evicted candidate cannot be evicted. For example it might be gone at the time when the method is executed. In this case it will indicate this condition by returning false.

Specified by:

tryEvict in interface EvictableStore<Data,QueryCacheRecord>

Parameters:

evictionCandidate - EvictionCandidate to be evicted

evictionListener - EvictionListener to listen evicted entries

Returns:

true if the candidate was evicted, otherwise returns false

sample

public Iterable<QueryCacheRecordHashMap.QueryCacheEvictableSamplingEntry> sample(int sampleCount)

Description copied from interface: SampleableEvictableStore

The sample method is used to sample a number of entries (defined by the samples parameter) from the internal data structure. This method should be executed in a constant time to deliver predictable timing results of the eviction system.

Specified by:

sample in interface SampleableEvictableStore<Data,QueryCacheRecord>

Parameters:

sampleCount - Entry count to be sampled

Returns:

Multiple EvictionCandidate to be evicted