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 Iterator<Map.Entry<com.hazelcast.nio.serialization.Data,R>>	expirationIterator
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
<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)
void	scanByNumberToDeleteExpired(com.hazelcast.internal.eviction.EvictionListener<com.hazelcast.nio.serialization.Data,R> evictionListener, com.hazelcast.internal.eviction.ExpirationChecker<R> expirationChecker, int maxScannableNum) Scans entries to delete expired ones.
<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

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

capacity, containsKey, containsValue, dispose, entryIter, 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

expirationIterator

protected Iterator<Map.Entry<com.hazelcast.nio.serialization.Data,R extends HiDensityRecord & com.hazelcast.internal.eviction.Evictable & com.hazelcast.internal.eviction.Expirable>> expirationIterator

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

scanByNumberToDeleteExpired

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

Scans entries to delete expired ones. This method is not thread safe and is called under lock. A background task calls this method periodically. We expect from this method to find and delete expired entries eventually. For this purpose, in each call, it only scans a fixed number of entries. expirationIterator is used for this scanning.

Parameters:

evictionListener - used to listen evicted entries

expirationChecker - used to check entries for expiry

maxScannableNum - scan at most this number of entries

See Also:

initExpirationIterator()

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>