com.hazelcast.map.impl.recordstore

Class HotRestartHDStorageImpl

java.lang.Object

com.hazelcast.map.impl.recordstore.HotRestartStorageImpl<HDRecord>

com.hazelcast.map.impl.recordstore.HotRestartHDStorageImpl

All Implemented Interfaces:

ForcedEvictable<HDRecord>, HotRestartStorage<HDRecord>, com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,HDRecord>

public class HotRestartHDStorageImpl
extends HotRestartStorageImpl<HDRecord>
implements ForcedEvictable<HDRecord>

Hot Restart storage implementation for maps configured with in-memory-format InMemoryFormat.NATIVE

Field Summary

Fields inherited from class com.hazelcast.map.impl.recordstore.HotRestartStorageImpl

fsync, hotRestartStore, mapServiceContext, prefix, storage

Constructor Summary

Constructors

Constructor and Description
HotRestartHDStorageImpl(EnterpriseMapServiceContext mapServiceContext, com.hazelcast.map.impl.record.RecordFactory recordFactory, com.hazelcast.config.InMemoryFormat inMemoryFormat, boolean fsync, long prefix, int partitionId)

Method Summary

Modifier and Type	Method and Description
void	clear(boolean isDuringShutdown)
com.hazelcast.spi.hotrestart.HotRestartKey	createHotRestartKey(HDRecord record)
com.hazelcast.map.impl.recordstore.Storage	createStorage(com.hazelcast.map.impl.record.RecordFactory recordFactory, com.hazelcast.config.InMemoryFormat inMemoryFormat)
void	destroy(boolean isDuringShutdown)
void	disposeDeferredBlocks()
com.hazelcast.spi.hotrestart.HotRestartStore	getHotRestartStore(int partitionId)
Object	getMutex()
long	getNativeKeyAddress(com.hazelcast.nio.serialization.Data key)
HDStorageImpl	getStorageImpl()
Iterator<HDRecord>	newForcedEvictionValuesIterator() Return iterator to be used for forced evictions.
void	put(com.hazelcast.nio.serialization.Data key, HDRecord record)
void	removeRecord(HDRecord record)
NativeMemoryData	toNative(com.hazelcast.nio.serialization.Data data)
void	updateRecordValue(com.hazelcast.nio.serialization.Data key, HDRecord record, Object val)

Methods inherited from class com.hazelcast.map.impl.recordstore.HotRestartStorageImpl

containsKey, extractRecordFromLazy, fetchEntries, fetchKeys, get, getEntryCostEstimator, getIfSameKey, getRandomSamples, isEmpty, mutationTolerantIterator, putToHotRestart, putTransient, removeTransient, setEntryCostEstimator, size, updateTransient, values

Methods inherited from class java.lang.Object

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

Constructor Detail

HotRestartHDStorageImpl

public HotRestartHDStorageImpl(EnterpriseMapServiceContext mapServiceContext,
                               com.hazelcast.map.impl.record.RecordFactory recordFactory,
                               com.hazelcast.config.InMemoryFormat inMemoryFormat,
                               boolean fsync,
                               long prefix,
                               int partitionId)

Method Detail

getHotRestartStore

public com.hazelcast.spi.hotrestart.HotRestartStore getHotRestartStore(int partitionId)

Overrides:

getHotRestartStore in class HotRestartStorageImpl<HDRecord>

createStorage

public com.hazelcast.map.impl.recordstore.Storage createStorage(com.hazelcast.map.impl.record.RecordFactory recordFactory,
                                                                com.hazelcast.config.InMemoryFormat inMemoryFormat)

Overrides:

createStorage in class HotRestartStorageImpl<HDRecord>

put

public void put(com.hazelcast.nio.serialization.Data key,
                HDRecord record)

Specified by:

put in interface com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,HDRecord>

Overrides:

put in class HotRestartStorageImpl<HDRecord>

updateRecordValue

public void updateRecordValue(com.hazelcast.nio.serialization.Data key,
                              HDRecord record,
                              Object val)

Specified by:

updateRecordValue in interface com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,HDRecord>

Overrides:

updateRecordValue in class HotRestartStorageImpl<HDRecord>

removeRecord

public void removeRecord(HDRecord record)

Specified by:

removeRecord in interface com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,HDRecord>

Overrides:

removeRecord in class HotRestartStorageImpl<HDRecord>

clear

public void clear(boolean isDuringShutdown)

Specified by:

clear in interface com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,HDRecord>

Overrides:

clear in class HotRestartStorageImpl<HDRecord>

destroy

public void destroy(boolean isDuringShutdown)

Specified by:

destroy in interface com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,HDRecord>

Overrides:

destroy in class HotRestartStorageImpl<HDRecord>

disposeDeferredBlocks

public void disposeDeferredBlocks()

Specified by:

disposeDeferredBlocks in interface com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,HDRecord>

Overrides:

disposeDeferredBlocks in class HotRestartStorageImpl<HDRecord>

createHotRestartKey

public com.hazelcast.spi.hotrestart.HotRestartKey createHotRestartKey(HDRecord record)

Overrides:

createHotRestartKey in class HotRestartStorageImpl<HDRecord>

getNativeKeyAddress

public long getNativeKeyAddress(com.hazelcast.nio.serialization.Data key)

toNative

public NativeMemoryData toNative(com.hazelcast.nio.serialization.Data data)

getStorageImpl

public HDStorageImpl getStorageImpl()

getMutex

public Object getMutex()

newForcedEvictionValuesIterator

public Iterator<HDRecord> newForcedEvictionValuesIterator()

Description copied from interface: ForcedEvictable

Return iterator to be used for forced evictions. This is not a general-purpose iterator, it's intended to be used exclusively for evictions. It does not guarantee to iterate over all entries and it can give you the same entries twice. This iterator does not have a fail-fast semantic. A caller can use Iterator.remove() method to remove a current record or a Storage.removeRecord(Object) - but it's only allowed to remove a record the iterator is currently pointing to. No other modification of the underlying storage is allowed while using this iterator.

Specified by:

newForcedEvictionValuesIterator in interface ForcedEvictable<HDRecord>

Returns: