com.hazelcast.map.impl.recordstore

Class StorageImpl<R extends Record>

java.lang.Object

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

Type Parameters:

R - the value type to be put in this storage.

All Implemented Interfaces:

Storage<Data,R>

public class StorageImpl<R extends Record>
extends Object
implements Storage<Data,R>

Default implementation of Storage layer used by a RecordStore

Method Summary

Methods

Modifier and Type	Method and Description
protected long	calculateHeapCost(Object obj)
void	clear(boolean isDuringShutdown)
boolean	containsKey(Data key)
void	destroy(boolean isDuringShutdown)
void	disposeDeferredBlocks()
MapEntriesWithCursor	fetchEntries(int tableIndex, int size, SerializationService serializationService)
MapKeysWithCursor	fetchKeys(int tableIndex, int size)
R	get(Data key)
R	getIfSameKey(Data key) Gives the same result as Storage.get(Object), but with the additional constraint that the supplied key must not just be equal to, but be exactly the same key blob (at the same memory address) as the one stored.
Iterable<LazyEntryViewFromRecord>	getRandomSamples(int sampleCount) Used for sampling based eviction, returns sampled entries.
SizeEstimator	getSizeEstimator()
boolean	isEmpty()
void	put(Data key, R record)
void	removeRecord(R record)
void	setSizeEstimator(SizeEstimator sizeEstimator)
int	size()
void	updateRecordValue(Data key, R record, Object value)
protected void	updateSizeEstimator(long recordSize)
Collection<R>	values()

Methods inherited from class java.lang.Object

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

Method Detail

clear

public void clear(boolean isDuringShutdown)

Specified by:

clear in interface Storage<Data,R extends Record>

values

public Collection<R> values()

Specified by:

values in interface Storage<Data,R extends Record>

put

public void put(Data key,
       R record)

Specified by:

put in interface Storage<Data,R extends Record>

updateRecordValue

public void updateRecordValue(Data key,
                     R record,
                     Object value)

Specified by:

updateRecordValue in interface Storage<Data,R extends Record>

get

public R get(Data key)

Specified by:

get in interface Storage<Data,R extends Record>

getIfSameKey

public R getIfSameKey(Data key)

Description copied from interface: Storage

Gives the same result as Storage.get(Object), but with the additional constraint that the supplied key must not just be equal to, but be exactly the same key blob (at the same memory address) as the one stored. The implementation of this method is only needed for the HD memory-based implementations.

Specified by:

getIfSameKey in interface Storage<Data,R extends Record>

size

public int size()

Specified by:

size in interface Storage<Data,R extends Record>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface Storage<Data,R extends Record>

destroy

public void destroy(boolean isDuringShutdown)

Specified by:

destroy in interface Storage<Data,R extends Record>

getSizeEstimator

public SizeEstimator getSizeEstimator()

Specified by:

getSizeEstimator in interface Storage<Data,R extends Record>

containsKey

public boolean containsKey(Data key)

Specified by:

containsKey in interface Storage<Data,R extends Record>

removeRecord

public void removeRecord(R record)

Specified by:

removeRecord in interface Storage<Data,R extends Record>

updateSizeEstimator

protected void updateSizeEstimator(long recordSize)

calculateHeapCost

protected long calculateHeapCost(Object obj)

setSizeEstimator

public void setSizeEstimator(SizeEstimator sizeEstimator)

Specified by:

setSizeEstimator in interface Storage<Data,R extends Record>

disposeDeferredBlocks

public void disposeDeferredBlocks()

Specified by:

disposeDeferredBlocks in interface Storage<Data,R extends Record>

getRandomSamples

public Iterable<LazyEntryViewFromRecord> getRandomSamples(int sampleCount)

Description copied from interface: Storage

Used for sampling based eviction, returns sampled entries.

Specified by:

getRandomSamples in interface Storage<Data,R extends Record>

Parameters:

sampleCount - sample count.

Returns:

sampled entries.

fetchKeys

public MapKeysWithCursor fetchKeys(int tableIndex,
                          int size)

Specified by:

fetchKeys in interface Storage<Data,R extends Record>

fetchEntries

public MapEntriesWithCursor fetchEntries(int tableIndex,
                                int size,
                                SerializationService serializationService)

Specified by:

fetchEntries in interface Storage<Data,R extends Record>