com.hazelcast.internal.hidensity.impl

Class EvictableHiDensityRecordMap<R extends HiDensityRecord & com.hazelcast.internal.eviction.Evictable & com.hazelcast.internal.eviction.Expirable>

java.lang.Object

com.hazelcast.elastic.map.BinaryElasticHashMap<V>

com.hazelcast.elastic.map.SampleableElasticHashMap<R>

com.hazelcast.internal.hidensity.impl.DefaultHiDensityRecordMap<R>

com.hazelcast.internal.hidensity.impl.EvictableHiDensityRecordMap<R>

Type Parameters:

R - type of the HiDensityRecord to be stored

All Implemented Interfaces:

com.hazelcast.elastic.map.ElasticMap<com.hazelcast.nio.serialization.Data,R>, com.hazelcast.internal.eviction.EvictableStore<com.hazelcast.nio.serialization.Data,R>, com.hazelcast.internal.eviction.EvictionListener<com.hazelcast.nio.serialization.Data,R>, HiDensityRecordMap<R>, com.hazelcast.nio.Disposable, Map<com.hazelcast.nio.serialization.Data,R>

Direct Known Subclasses:

SampleableEvictableHiDensityRecordMap

public class EvictableHiDensityRecordMap<R extends HiDensityRecord & com.hazelcast.internal.eviction.Evictable & com.hazelcast.internal.eviction.Expirable>
extends DefaultHiDensityRecordMap<R>
implements com.hazelcast.internal.eviction.EvictableStore<com.hazelcast.nio.serialization.Data,R>, com.hazelcast.internal.eviction.EvictionListener<com.hazelcast.nio.serialization.Data,R>

Nested Class Summary

Nested classes/interfaces inherited from class com.hazelcast.elastic.map.SampleableElasticHashMap

SampleableElasticHashMap.IterableSamplingEntry, SampleableElasticHashMap.SamplingEntry

Nested classes/interfaces inherited from class com.hazelcast.elastic.map.BinaryElasticHashMap

BinaryElasticHashMap.KeyIter, BinaryElasticHashMap.MapEntry, BinaryElasticHashMap.RandomKeyIter, BinaryElasticHashMap.RandomValueIter, BinaryElasticHashMap.ValueIter

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

Map.Entry<K,V>

Field Summary

Fields

Modifier and Type	Field and Description
protected NativeMemoryData	keyHolder
protected static int	MIN_EVICTION_ELEMENT_COUNT
protected static int	ONE_HUNDRED_PERCENT

Fields inherited from class com.hazelcast.internal.hidensity.impl.DefaultHiDensityRecordMap

recordProcessor, storageInfo

Fields inherited from class com.hazelcast.elastic.map.BinaryElasticHashMap

accessor, HEADER_LENGTH_IN_BYTES, memoryBlockProcessor

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

NO_LISTENER

Constructor Summary

Constructors

Constructor and Description
EvictableHiDensityRecordMap(int initialCapacity, HiDensityRecordProcessor<R> recordProcessor, HiDensityStorageInfo storageInfo)

Method Summary

Modifier and Type	Method and Description
protected <C extends com.hazelcast.internal.eviction.EvictionCandidate<com.hazelcast.nio.serialization.Data,R>> int	doEvictExpiredRecords(com.hazelcast.internal.eviction.EvictionListener<com.hazelcast.nio.serialization.Data,R> evictionListener, com.hazelcast.internal.eviction.ExpirationChecker<R> expirationChecker)
int	evictExpiredRecords()
int	evictExpiredRecords(com.hazelcast.internal.eviction.EvictionListener<com.hazelcast.nio.serialization.Data,R> evictionListener)
int	evictExpiredRecords(com.hazelcast.internal.eviction.EvictionListener<com.hazelcast.nio.serialization.Data,R> evictionListener, com.hazelcast.internal.eviction.ExpirationChecker<R> expirationChecker)
int	evictExpiredRecords(com.hazelcast.internal.eviction.ExpirationChecker<R> expirationChecker)
<C extends com.hazelcast.internal.eviction.EvictionCandidate<com.hazelcast.nio.serialization.Data,R>> int	forceEvict(int evictionPercentage, com.hazelcast.internal.eviction.EvictionListener<com.hazelcast.nio.serialization.Data,R> evictionListener) Forcefully evict records with the given evictionPercentage.
void	onEvict(com.hazelcast.nio.serialization.Data evictedEntryAccessor, R evictedEntry, boolean wasExpired)
<C extends com.hazelcast.internal.eviction.EvictionCandidate<com.hazelcast.nio.serialization.Data,R>> boolean	tryEvict(C evictionCandidate, com.hazelcast.internal.eviction.EvictionListener<com.hazelcast.nio.serialization.Data,R> evictionListener)

Methods inherited from class com.hazelcast.internal.hidensity.impl.DefaultHiDensityRecordMap

clear, decreaseEntryCount, decreaseEntryCount, delete, increaseEntryCount, iterator, onOome, put, putIfAbsent, remove, remove, set

Methods inherited from class com.hazelcast.elastic.map.SampleableElasticHashMap

createSamplingEntry, getRandomSamples, isValidForSampling

Methods inherited from class com.hazelcast.elastic.map.BinaryElasticHashMap

capacity, containsKey, containsValue, dispose, entryIter, entrySet, get, getIfSameKey, getNativeKeyAddress, isEmpty, keyIter, keySet, loadFromOffHeapHeader, newRandomEvictionKeyIterator, newRandomEvictionValueIterator, putAll, readV, replace, replace, size, storeHeaderOffHeap, toString, valueIter, valueIter, values

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, 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

Field Detail

ONE_HUNDRED_PERCENT

protected static final int ONE_HUNDRED_PERCENT

See Also:

Constant Field Values

MIN_EVICTION_ELEMENT_COUNT

protected static final int MIN_EVICTION_ELEMENT_COUNT

See Also:

Constant Field Values

keyHolder

protected final NativeMemoryData keyHolder

Constructor Detail

EvictableHiDensityRecordMap

public EvictableHiDensityRecordMap(int initialCapacity,
                                   HiDensityRecordProcessor<R> recordProcessor,
                                   HiDensityStorageInfo storageInfo)

Method Detail

forceEvict

public <C extends com.hazelcast.internal.eviction.EvictionCandidate<com.hazelcast.nio.serialization.Data,R>> int forceEvict(int evictionPercentage,
                                                                                                                            com.hazelcast.internal.eviction.EvictionListener<com.hazelcast.nio.serialization.Data,R> evictionListener)

Forcefully evict records with the given evictionPercentage.

Parameters:

evictionPercentage - percentage to determine how many records will be evicted

evictionListener - EvictionListener to be notified about evicted key and value

Returns:

evicted entry count

evictExpiredRecords

public int evictExpiredRecords()

evictExpiredRecords

public int evictExpiredRecords(com.hazelcast.internal.eviction.EvictionListener<com.hazelcast.nio.serialization.Data,R> evictionListener)

evictExpiredRecords

public int evictExpiredRecords(com.hazelcast.internal.eviction.ExpirationChecker<R> expirationChecker)

evictExpiredRecords

public int evictExpiredRecords(com.hazelcast.internal.eviction.EvictionListener<com.hazelcast.nio.serialization.Data,R> evictionListener,
                               com.hazelcast.internal.eviction.ExpirationChecker<R> expirationChecker)

doEvictExpiredRecords

protected <C extends com.hazelcast.internal.eviction.EvictionCandidate<com.hazelcast.nio.serialization.Data,R>> int doEvictExpiredRecords(com.hazelcast.internal.eviction.EvictionListener<com.hazelcast.nio.serialization.Data,R> evictionListener,
                                                                                                                                          com.hazelcast.internal.eviction.ExpirationChecker<R> expirationChecker)

tryEvict

public <C extends com.hazelcast.internal.eviction.EvictionCandidate<com.hazelcast.nio.serialization.Data,R>> boolean tryEvict(C evictionCandidate,
                                                                                                                              com.hazelcast.internal.eviction.EvictionListener<com.hazelcast.nio.serialization.Data,R> evictionListener)

Specified by:

tryEvict in interface com.hazelcast.internal.eviction.EvictableStore<com.hazelcast.nio.serialization.Data,R extends HiDensityRecord & com.hazelcast.internal.eviction.Evictable & com.hazelcast.internal.eviction.Expirable>

onEvict

public void onEvict(com.hazelcast.nio.serialization.Data evictedEntryAccessor,
                    R evictedEntry,
                    boolean wasExpired)

Specified by:

onEvict in interface com.hazelcast.internal.eviction.EvictionListener<com.hazelcast.nio.serialization.Data,R extends HiDensityRecord & com.hazelcast.internal.eviction.Evictable & com.hazelcast.internal.eviction.Expirable>