com.hazelcast.cache.impl.record

Class CacheRecordHashMap

java.lang.Object

java.util.AbstractMap<K,V>

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

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

com.hazelcast.cache.impl.record.CacheRecordHashMap

All Implemented Interfaces:

CacheRecordMap<Data,CacheRecord>, SampleableCacheRecordMap<Data,CacheRecord>, EvictableStore<Data,CacheRecord>, SampleableEvictableStore<Data,CacheRecord>, IConcurrentMap<Data,CacheRecord>, Serializable, ConcurrentMap<Data,CacheRecord>, Map<Data,CacheRecord>

public class CacheRecordHashMap
extends SampleableConcurrentHashMap<Data,CacheRecord>
implements SampleableCacheRecordMap<Data,CacheRecord>

See Also:

Serialized Form

Nested Class Summary

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
CacheRecordHashMap(SerializationService serializationService, int initialCapacity, CacheContext cacheContext)

Method Summary

Modifier and Type	Method and Description
void	clear() Removes all of the mappings from this map.
protected com.hazelcast.cache.impl.record.CacheRecordHashMap.CacheEvictableSamplingEntry	createSamplingEntry(Data key, CacheRecord value)
CacheEntryIterationResult	fetchEntries(int nextTableIndex, int size) Fetches entries in bulk as specified size at most.
CacheKeyIterationResult	fetchKeys(int nextTableIndex, int size) Fetches keys in bulk as specified size at most.
CacheRecord	put(Data key, CacheRecord value) Maps the specified key to the specified value in this table.
CacheRecord	putIfAbsent(Data key, CacheRecord value)
CacheRecord	remove(Object key) Removes the key (and its corresponding value) from this map.
boolean	remove(Object key, Object value)
Iterable<com.hazelcast.cache.impl.record.CacheRecordHashMap.CacheEvictableSamplingEntry>	sample(int sampleCount) The sample method is used to sample a number of entries (defined by the samples parameter) from the internal data structure.
void	setEntryCounting(boolean enable) Sets the entry counting behaviour.
<C extends EvictionCandidate<Data,CacheRecord>> boolean	tryEvict(C evictionCandidate, EvictionListener<Data,CacheRecord> 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, contains, containsKey, containsValue, elements, entrySet, get, isEmpty, keys, keySet, purgeStaleEntries, putAll, 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.Map

compute, computeIfAbsent, computeIfPresent, containsKey, containsValue, entrySet, equals, forEach, get, getOrDefault, hashCode, isEmpty, keySet, merge, putAll, replace, replace, replaceAll, size, values

Methods inherited from interface java.util.concurrent.ConcurrentMap

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

Constructor Detail

CacheRecordHashMap

public CacheRecordHashMap(SerializationService serializationService,
                          int initialCapacity,
                          CacheContext cacheContext)

Method Detail

setEntryCounting

public void setEntryCounting(boolean enable)

Description copied from interface: CacheRecordMap

Sets the entry counting behaviour. Because, records on backup partitions should not be counted.

Specified by:

setEntryCounting in interface CacheRecordMap<Data,CacheRecord>

Parameters:

enable - enables the entry counting behaviour if it is true, otherwise disables.

put

public CacheRecord put(Data key,
                       CacheRecord value)

Description copied from class: ConcurrentReferenceHashMap

Maps the specified key to the specified value in this table. Neither the key nor the value can be null.

The value can be retrieved by calling the get method with a key that is equal to the original key.

Specified by:

put in interface Map<Data,CacheRecord>

Overrides:

put in class ConcurrentReferenceHashMap<Data,CacheRecord>

Parameters:

key - key with which the specified value is to be associated

value - value to be associated with the specified key

Returns:

the previous value associated with key, or null if there was no mapping for key

putIfAbsent

public CacheRecord putIfAbsent(Data key,
                               CacheRecord value)

Description copied from class: ConcurrentReferenceHashMap

Specified by:

putIfAbsent in interface ConcurrentMap<Data,CacheRecord>

Specified by:

putIfAbsent in interface Map<Data,CacheRecord>

Overrides:

putIfAbsent in class ConcurrentReferenceHashMap<Data,CacheRecord>

Returns:

the previous value associated with the specified key, or null if there was no mapping for the key

remove

public CacheRecord remove(Object key)

Description copied from class: ConcurrentReferenceHashMap

Removes the key (and its corresponding value) from this map. This method does nothing if the key is not in the map.

Specified by:

remove in interface Map<Data,CacheRecord>

Overrides:

remove in class ConcurrentReferenceHashMap<Data,CacheRecord>

Parameters:

key - the key that needs to be removed

Returns:

the previous value associated with key, or null if there was no mapping for key

remove

public boolean remove(Object key,
                      Object value)

Description copied from class: ConcurrentReferenceHashMap

Specified by:

remove in interface ConcurrentMap<Data,CacheRecord>

Specified by:

remove in interface Map<Data,CacheRecord>

Overrides:

remove in class ConcurrentReferenceHashMap<Data,CacheRecord>

clear

public void clear()

Description copied from class: ConcurrentReferenceHashMap

Removes all of the mappings from this map.

Specified by:

clear in interface Map<Data,CacheRecord>

Overrides:

clear in class ConcurrentReferenceHashMap<Data,CacheRecord>

createSamplingEntry

protected com.hazelcast.cache.impl.record.CacheRecordHashMap.CacheEvictableSamplingEntry createSamplingEntry(Data key,
                                                                                                             CacheRecord value)

Overrides:

createSamplingEntry in class SampleableConcurrentHashMap<Data,CacheRecord>

fetchKeys

public CacheKeyIterationResult fetchKeys(int nextTableIndex,
                                         int size)

Description copied from interface: CacheRecordMap

Fetches keys in bulk as specified size at most.

Specified by:

fetchKeys in interface CacheRecordMap<Data,CacheRecord>

Parameters:

nextTableIndex - starting point for fetching

size - maximum bulk size to fetch the keys

Returns:

the CacheKeyIterationResult instance contains fetched keys

fetchEntries

public CacheEntryIterationResult fetchEntries(int nextTableIndex,
                                              int size)

Description copied from interface: CacheRecordMap

Fetches entries in bulk as specified size at most.

Specified by:

fetchEntries in interface CacheRecordMap<Data,CacheRecord>

Parameters:

nextTableIndex - starting point for fetching

size - maximum bulk size to fetch the entries

Returns:

the CacheEntryIterationResult instance contains fetched keys

tryEvict

public <C extends EvictionCandidate<Data,CacheRecord>> boolean tryEvict(C evictionCandidate,
                                                                        EvictionListener<Data,CacheRecord> 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,CacheRecord>

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<com.hazelcast.cache.impl.record.CacheRecordHashMap.CacheEvictableSamplingEntry> 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,CacheRecord>

Parameters:

sampleCount - Entry count to be sampled

Returns:

Multiple EvictionCandidate to be evicted