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()
R	get(Data key)
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>

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.