com.hazelcast.map.impl.recordstore

Class HDStorageImpl

java.lang.Object

com.hazelcast.map.impl.recordstore.HDStorageImpl

All Implemented Interfaces:

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

public class HDStorageImpl
extends Object
implements com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,HDRecord>, ForcedEvictable<HDRecord>

Hi-Density backed Storage implementation for IMap. This implementation can be used under multi-thread access.

Constructor Summary

Constructors

Constructor and Description
HDStorageImpl(HiDensityRecordProcessor<HDRecord> recordProcessor, com.hazelcast.spi.serialization.SerializationService serializationService)

Method Summary

Modifier and Type	Method and Description
protected void	addDeferredDispose(Object memoryBlock)
void	clear(boolean isDuringShutdown)
boolean	containsKey(com.hazelcast.nio.serialization.Data key)
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)
HDRecord	get(com.hazelcast.nio.serialization.Data key)
com.hazelcast.map.impl.EntryCostEstimator	getEntryCostEstimator()
HDRecord	getIfSameKey(com.hazelcast.nio.serialization.Data key)
long	getNativeKeyAddress(com.hazelcast.nio.serialization.Data key)
Iterable	getRandomSamples(int sampleCount)
HiDensityRecordProcessor	getRecordProcessor()
boolean	isEmpty()
Iterator<HDRecord>	mutationTolerantIterator()
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)
void	setEntryCostEstimator(com.hazelcast.map.impl.EntryCostEstimator entryCostEstimator)
int	size()
protected NativeMemoryData	toNative(com.hazelcast.nio.serialization.Data key)
void	updateRecordValue(com.hazelcast.nio.serialization.Data ignored, HDRecord record, Object value)
Collection<HDRecord>	values()

Methods inherited from class java.lang.Object

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

Constructor Detail

HDStorageImpl

public HDStorageImpl(HiDensityRecordProcessor<HDRecord> recordProcessor,
                     com.hazelcast.spi.serialization.SerializationService serializationService)

Method Detail

getRecordProcessor

public HiDensityRecordProcessor getRecordProcessor()

removeRecord

public void removeRecord(HDRecord record)

Specified by:

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

containsKey

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

Specified by:

containsKey in interface com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,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>

updateRecordValue

public void updateRecordValue(com.hazelcast.nio.serialization.Data ignored,
                              HDRecord record,
                              Object value)

Specified by:

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

get

public HDRecord get(com.hazelcast.nio.serialization.Data key)

Specified by:

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

getIfSameKey

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

Specified by:

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

clear

public void clear(boolean isDuringShutdown)

Specified by:

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

values

public Collection<HDRecord> values()

Specified by:

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

mutationTolerantIterator

public Iterator<HDRecord> mutationTolerantIterator()

Specified by:

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

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:

size

public int size()

Specified by:

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

isEmpty

public boolean isEmpty()

Specified by:

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

destroy

public void destroy(boolean isDuringShutdown)

Specified by:

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

getEntryCostEstimator

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

Specified by:

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

setEntryCostEstimator

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

Specified by:

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

disposeDeferredBlocks

public void disposeDeferredBlocks()

Specified by:

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

addDeferredDispose

protected void addDeferredDispose(Object memoryBlock)

toNative

protected NativeMemoryData toNative(com.hazelcast.nio.serialization.Data key)

getRandomSamples

public Iterable getRandomSamples(int sampleCount)

Specified by:

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

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,HDRecord>

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,HDRecord>

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,HDRecord>

getNativeKeyAddress

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