com.hazelcast.internal.nearcache.impl.nativememory

Class SegmentedNativeMemoryNearCacheRecordStore<K,V>

java.lang.Object

com.hazelcast.internal.nearcache.impl.nativememory.SegmentedNativeMemoryNearCacheRecordStore<K,V>

Type Parameters:

K - the type of the key stored in Near Cache

V - the type of the value stored in Near Cache

All Implemented Interfaces:

HiDensityRecordStore<NativeMemoryNearCacheRecord>, HiDensityNearCacheRecordStore<K,V,NativeMemoryNearCacheRecord>, com.hazelcast.internal.nearcache.NearCacheRecordStore<K,V>, com.hazelcast.spi.InitializingObject

public class SegmentedNativeMemoryNearCacheRecordStore<K,V>
extends Object
implements HiDensityNearCacheRecordStore<K,V,NativeMemoryNearCacheRecord>

Segmented HiDensityNearCacheRecordStore which improves performance by using multiple NativeMemoryNearCacheRecordStore instances in parallel.

Field Summary

Fields inherited from interface com.hazelcast.internal.hidensity.HiDensityRecordStore

DEFAULT_FORCED_EVICTION_PERCENTAGE, FORCE_EVICTION_TRY_COUNT, HUNDRED_PERCENT, NULL_PTR

Constructor Summary

Constructors

Constructor and Description
SegmentedNativeMemoryNearCacheRecordStore(String name, com.hazelcast.config.NearCacheConfig nearCacheConfig, EnterpriseSerializationService serializationService, ClassLoader classLoader)

Method Summary

Modifier and Type	Method and Description
void	clear()
void	destroy()
void	doEviction()
void	doEvictionIfRequired()
void	doExpiration()
int	forceEvict() Forcefully evict records.
V	get(K key)
com.hazelcast.memory.HazelcastMemoryManager	getMemoryManager() Gets underlying MemoryManager implementation.
com.hazelcast.monitor.NearCacheStats	getNearCacheStats()
com.hazelcast.internal.nearcache.NearCacheRecord	getRecord(K key)
com.hazelcast.internal.nearcache.impl.invalidation.StaleReadDetector	getStaleReadDetector()
void	initialize()
void	invalidate(K key)
void	loadKeys(com.hazelcast.internal.adapter.DataStructureAdapter<Object,?> adapter)
void	put(K key, com.hazelcast.nio.serialization.Data keyData, V value)
Object	selectToSave(Object... candidates)
void	setStaleReadDetector(com.hazelcast.internal.nearcache.impl.invalidation.StaleReadDetector staleReadDetector)
int	size()
void	storeKeys()
V	tryPublishReserved(K key, V value, long reservationId, boolean deserialize)
long	tryReserveForUpdate(K key, com.hazelcast.nio.serialization.Data keyData)

Methods inherited from class java.lang.Object

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

Constructor Detail

SegmentedNativeMemoryNearCacheRecordStore

public SegmentedNativeMemoryNearCacheRecordStore(String name,
                                                 com.hazelcast.config.NearCacheConfig nearCacheConfig,
                                                 EnterpriseSerializationService serializationService,
                                                 ClassLoader classLoader)

Method Detail

initialize

public void initialize()

Specified by:

initialize in interface com.hazelcast.spi.InitializingObject

get

public V get(K key)

Specified by:

get in interface com.hazelcast.internal.nearcache.NearCacheRecordStore<K,V>

getRecord

public com.hazelcast.internal.nearcache.NearCacheRecord getRecord(K key)

Specified by:

getRecord in interface com.hazelcast.internal.nearcache.NearCacheRecordStore<K,V>

put

public void put(K key,
                com.hazelcast.nio.serialization.Data keyData,
                V value)

Specified by:

put in interface com.hazelcast.internal.nearcache.NearCacheRecordStore<K,V>

invalidate

public void invalidate(K key)

Specified by:

invalidate in interface com.hazelcast.internal.nearcache.NearCacheRecordStore<K,V>

clear

public void clear()

Specified by:

clear in interface com.hazelcast.internal.nearcache.NearCacheRecordStore<K,V>

destroy

public void destroy()

Specified by:

destroy in interface com.hazelcast.internal.nearcache.NearCacheRecordStore<K,V>

getNearCacheStats

public com.hazelcast.monitor.NearCacheStats getNearCacheStats()

Specified by:

getNearCacheStats in interface com.hazelcast.internal.nearcache.NearCacheRecordStore<K,V>

selectToSave

public Object selectToSave(Object... candidates)

Specified by:

selectToSave in interface com.hazelcast.internal.nearcache.NearCacheRecordStore<K,V>

size

public int size()

Specified by:

size in interface com.hazelcast.internal.nearcache.NearCacheRecordStore<K,V>

forceEvict

public int forceEvict()

Description copied from interface: HiDensityRecordStore

Forcefully evict records.

Specified by:

forceEvict in interface HiDensityRecordStore<NativeMemoryNearCacheRecord>

Returns:

evicted entry count.

doExpiration

public void doExpiration()

Specified by:

doExpiration in interface com.hazelcast.internal.nearcache.NearCacheRecordStore<K,V>

doEvictionIfRequired

public void doEvictionIfRequired()

Specified by:

doEvictionIfRequired in interface com.hazelcast.internal.nearcache.NearCacheRecordStore<K,V>

doEviction

public void doEviction()

Specified by:

doEviction in interface com.hazelcast.internal.nearcache.NearCacheRecordStore<K,V>

loadKeys

public void loadKeys(com.hazelcast.internal.adapter.DataStructureAdapter<Object,?> adapter)

Specified by:

loadKeys in interface com.hazelcast.internal.nearcache.NearCacheRecordStore<K,V>

storeKeys

public void storeKeys()

Specified by:

storeKeys in interface com.hazelcast.internal.nearcache.NearCacheRecordStore<K,V>

setStaleReadDetector

public void setStaleReadDetector(com.hazelcast.internal.nearcache.impl.invalidation.StaleReadDetector staleReadDetector)

Specified by:

setStaleReadDetector in interface com.hazelcast.internal.nearcache.NearCacheRecordStore<K,V>

getStaleReadDetector

public com.hazelcast.internal.nearcache.impl.invalidation.StaleReadDetector getStaleReadDetector()

Specified by:

getStaleReadDetector in interface com.hazelcast.internal.nearcache.NearCacheRecordStore<K,V>

tryReserveForUpdate

public long tryReserveForUpdate(K key,
                                com.hazelcast.nio.serialization.Data keyData)

Specified by:

tryReserveForUpdate in interface com.hazelcast.internal.nearcache.NearCacheRecordStore<K,V>

tryPublishReserved

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

Specified by:

tryPublishReserved in interface com.hazelcast.internal.nearcache.NearCacheRecordStore<K,V>

getMemoryManager

public com.hazelcast.memory.HazelcastMemoryManager getMemoryManager()

Description copied from interface: HiDensityNearCacheRecordStore

Gets underlying MemoryManager implementation.

Specified by:

getMemoryManager in interface HiDensityNearCacheRecordStore<K,V,NativeMemoryNearCacheRecord>

Returns:

the underlying MemoryManager implementation.