com.hazelcast.map.impl.recordstore

Class HotRestartStorageImpl<R extends com.hazelcast.map.impl.record.Record>

java.lang.Object

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

All Implemented Interfaces:

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

Direct Known Subclasses:

HotRestartHDStorageImpl

public class HotRestartStorageImpl<R extends com.hazelcast.map.impl.record.Record>
extends Object
implements com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,R>, HotRestartStorage<R>

Hot Restart storage implementation for maps not configured with in-memory-format: InMemoryFormat.NATIVE For InMemoryFormat.NATIVE please see HotRestartHDStorageImpl.

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	fsync
protected com.hazelcast.spi.hotrestart.HotRestartStore	hotRestartStore
protected EnterpriseMapServiceContext	mapServiceContext
protected long	prefix
protected com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,R>	storage

Method Summary

Modifier and Type	Method and Description
void	clear(boolean isDuringShutdown)
boolean	containsKey(com.hazelcast.nio.serialization.Data key)
com.hazelcast.spi.hotrestart.HotRestartKey	createHotRestartKey(R 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.map.impl.record.Record	extractRecordFromLazy(com.hazelcast.core.EntryView entryView)
com.hazelcast.map.impl.iterator.MapEntriesWithCursor	fetchEntries(int tableIndex, int size, com.hazelcast.spi.serialization.SerializationService serializationService)
com.hazelcast.map.impl.iterator.MapKeysWithCursor	fetchKeys(int tableIndex, int size)
R	get(com.hazelcast.nio.serialization.Data key)
com.hazelcast.map.impl.EntryCostEstimator	getEntryCostEstimator()
com.hazelcast.spi.hotrestart.HotRestartStore	getHotRestartStore(int partitionId)
R	getIfSameKey(com.hazelcast.nio.serialization.Data key)
Iterable<com.hazelcast.core.EntryView>	getRandomSamples(int sampleCount)
boolean	isEmpty()
Iterator<R>	mutationTolerantIterator()
void	put(com.hazelcast.nio.serialization.Data key, R record)
protected void	putToHotRestart(R record)
void	putTransient(com.hazelcast.nio.serialization.Data key, R record)
void	removeRecord(R record)
void	removeTransient(R record)
void	setEntryCostEstimator(com.hazelcast.map.impl.EntryCostEstimator entryCostEstimator)
int	size()
void	updateRecordValue(com.hazelcast.nio.serialization.Data key, R record, Object value)
void	updateTransient(com.hazelcast.nio.serialization.Data key, R record, Object value)
Collection<R>	values()

Methods inherited from class java.lang.Object

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

Field Detail

mapServiceContext

protected final EnterpriseMapServiceContext mapServiceContext

hotRestartStore

protected final com.hazelcast.spi.hotrestart.HotRestartStore hotRestartStore

storage

protected final com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,R extends com.hazelcast.map.impl.record.Record> storage

fsync

protected final boolean fsync

prefix

protected final long prefix

Method Detail

getHotRestartStore

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

createStorage

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

putTransient

public final void putTransient(com.hazelcast.nio.serialization.Data key,
                               R record)

Specified by:

putTransient in interface HotRestartStorage<R extends com.hazelcast.map.impl.record.Record>

updateTransient

public final void updateTransient(com.hazelcast.nio.serialization.Data key,
                                  R record,
                                  Object value)

Specified by:

updateTransient in interface HotRestartStorage<R extends com.hazelcast.map.impl.record.Record>

removeTransient

public final void removeTransient(R record)

Specified by:

removeTransient in interface HotRestartStorage<R extends com.hazelcast.map.impl.record.Record>

put

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

Specified by:

put in interface com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,R extends com.hazelcast.map.impl.record.Record>

updateRecordValue

public void updateRecordValue(com.hazelcast.nio.serialization.Data key,
                              R record,
                              Object value)

Specified by:

updateRecordValue in interface com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,R extends com.hazelcast.map.impl.record.Record>

removeRecord

public void removeRecord(R record)

Specified by:

removeRecord in interface com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,R extends com.hazelcast.map.impl.record.Record>

clear

public void clear(boolean isDuringShutdown)

Specified by:

clear in interface com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,R extends com.hazelcast.map.impl.record.Record>

destroy

public void destroy(boolean isDuringShutdown)

Specified by:

destroy in interface com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,R extends com.hazelcast.map.impl.record.Record>

get

public final R get(com.hazelcast.nio.serialization.Data key)

Specified by:

get in interface com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,R extends com.hazelcast.map.impl.record.Record>

getIfSameKey

public R getIfSameKey(com.hazelcast.nio.serialization.Data key)

Specified by:

getIfSameKey in interface com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,R extends com.hazelcast.map.impl.record.Record>

containsKey

public final boolean containsKey(com.hazelcast.nio.serialization.Data key)

Specified by:

containsKey in interface com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,R extends com.hazelcast.map.impl.record.Record>

values

public Collection<R> values()

Specified by:

values in interface com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,R extends com.hazelcast.map.impl.record.Record>

mutationTolerantIterator

public final Iterator<R> mutationTolerantIterator()

Specified by:

mutationTolerantIterator in interface com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,R extends com.hazelcast.map.impl.record.Record>

size

public final int size()

Specified by:

size in interface com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,R extends com.hazelcast.map.impl.record.Record>

isEmpty

public final boolean isEmpty()

Specified by:

isEmpty in interface com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,R extends com.hazelcast.map.impl.record.Record>

getEntryCostEstimator

public final com.hazelcast.map.impl.EntryCostEstimator getEntryCostEstimator()

Specified by:

getEntryCostEstimator in interface com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,R extends com.hazelcast.map.impl.record.Record>

setEntryCostEstimator

public final void setEntryCostEstimator(com.hazelcast.map.impl.EntryCostEstimator entryCostEstimator)

Specified by:

setEntryCostEstimator in interface com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,R extends com.hazelcast.map.impl.record.Record>

disposeDeferredBlocks

public void disposeDeferredBlocks()

Specified by:

disposeDeferredBlocks in interface com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,R extends com.hazelcast.map.impl.record.Record>

getRandomSamples

public Iterable<com.hazelcast.core.EntryView> getRandomSamples(int sampleCount)

Specified by:

getRandomSamples in interface com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,R extends com.hazelcast.map.impl.record.Record>

fetchKeys

public com.hazelcast.map.impl.iterator.MapKeysWithCursor fetchKeys(int tableIndex,
                                                                   int size)

Specified by:

fetchKeys in interface com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,R extends com.hazelcast.map.impl.record.Record>

fetchEntries

public com.hazelcast.map.impl.iterator.MapEntriesWithCursor fetchEntries(int tableIndex,
                                                                         int size,
                                                                         com.hazelcast.spi.serialization.SerializationService serializationService)

Specified by:

fetchEntries in interface com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,R extends com.hazelcast.map.impl.record.Record>

extractRecordFromLazy

public com.hazelcast.map.impl.record.Record extractRecordFromLazy(com.hazelcast.core.EntryView entryView)

Specified by:

extractRecordFromLazy in interface com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,R extends com.hazelcast.map.impl.record.Record>

createHotRestartKey

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

putToHotRestart

protected final void putToHotRestart(R record)