com.hazelcast.map

Class DefaultRecordStore

java.lang.Object

com.hazelcast.map.DefaultRecordStore

All Implemented Interfaces:

RecordStore

public class DefaultRecordStore
extends Object
implements RecordStore

Author:

enesakar 1/17/13

Constructor Summary

Constructors

Constructor and Description
DefaultRecordStore(String name, MapService mapService, int partitionId)

Method Summary

Modifier and Type	Method and Description
boolean	canAcquireLock(Data key, String caller, long threadId)
void	checkIfLoaded()
void	clear()
void	clearPartition()
boolean	containsKey(Data dataKey)
boolean	containsValue(Object value)
void	deleteRecord(Data key)
Set<Map.Entry<Data,Data>>	entrySetData()
Set<Map.Entry<Data,Object>>	entrySetObject()
Object	evict(Data dataKey)
boolean	extendLock(Data key, String caller, long threadId, long ttl)
void	flush()
boolean	forceUnlock(Data dataKey)
Object	get(Data dataKey)
MapEntrySet	getAll(Set<Data> keySet)
long	getHeapCost()
String	getLockOwnerInfo(Data key)
MapContainer	getMapContainer()
Map.Entry<Data,Object>	getMapEntry(Data dataKey)
Map.Entry<Data,Object>	getMapEntryForBackup(Data dataKey)
String	getName()
Map<Data,Record>	getReadonlyRecordMap()
Record	getRecord(Data key)
SizeEstimator	getSizeEstimator()
boolean	isEmpty()
boolean	isLoaded()
boolean	isLocked(Data dataKey)
boolean	isLockedBy(Data key, String caller, long threadId)
Set<Data>	keySet()
boolean	lock(Data key, String caller, long threadId, long ttl)
boolean	merge(Data dataKey, EntryView mergingEntry, MapMergePolicy mergePolicy)
Object	put(Data dataKey, Object value, long ttl)
void	put(Map.Entry<Data,Object> entry)
Record	putBackup(Data key, Object value)
Record	putBackup(Data key, Object value, long ttl, boolean shouldSchedule)
void	putFromLoad(Data dataKey, Object value, long ttl)
Object	putIfAbsent(Data dataKey, Object value, long ttl)
void	putRecord(Data key, Record record)
void	putTransient(Data dataKey, Object value, long ttl)
Object	remove(Data dataKey)
boolean	remove(Data dataKey, Object testValue)
Object	replace(Data dataKey, Object value)
boolean	replace(Data dataKey, Object testValue, Object newValue)
void	reset()
boolean	set(Data dataKey, Object value, long ttl)
void	setLoaded(boolean isLoaded)
int	size()
boolean	tryPut(Data dataKey, Object value, long ttl)
boolean	txnLock(Data key, String caller, long threadId, long ttl)
boolean	unlock(Data key, String caller, long threadId)
Collection<Data>	valuesData()
Collection<Object>	valuesObject()

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultRecordStore

public DefaultRecordStore(String name,
                          MapService mapService,
                          int partitionId)

Method Detail

isLoaded

public boolean isLoaded()

Specified by:

isLoaded in interface RecordStore

setLoaded

public void setLoaded(boolean isLoaded)

Specified by:

setLoaded in interface RecordStore

checkIfLoaded

public void checkIfLoaded()

Specified by:

checkIfLoaded in interface RecordStore

getName

public String getName()

Specified by:

getName in interface RecordStore

flush

public void flush()

Specified by:

flush in interface RecordStore

getMapContainer

public MapContainer getMapContainer()

Specified by:

getMapContainer in interface RecordStore

getRecord

public Record getRecord(Data key)

Specified by:

getRecord in interface RecordStore

putRecord

public void putRecord(Data key,
                      Record record)

Specified by:

putRecord in interface RecordStore

putBackup

public Record putBackup(Data key,
                        Object value)

Specified by:

putBackup in interface RecordStore

putBackup

public Record putBackup(Data key,
                        Object value,
                        long ttl,
                        boolean shouldSchedule)

Specified by:

putBackup in interface RecordStore

deleteRecord

public void deleteRecord(Data key)

Specified by:

deleteRecord in interface RecordStore

getReadonlyRecordMap

public Map<Data,Record> getReadonlyRecordMap()

Specified by:

getReadonlyRecordMap in interface RecordStore

clearPartition

public void clearPartition()

Specified by:

clearPartition in interface RecordStore

size

public int size()

Specified by:

size in interface RecordStore

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface RecordStore

containsValue

public boolean containsValue(Object value)

Specified by:

containsValue in interface RecordStore

lock

public boolean lock(Data key,
                    String caller,
                    long threadId,
                    long ttl)

Specified by:

lock in interface RecordStore

txnLock

public boolean txnLock(Data key,
                       String caller,
                       long threadId,
                       long ttl)

Specified by:

txnLock in interface RecordStore

extendLock

public boolean extendLock(Data key,
                          String caller,
                          long threadId,
                          long ttl)

Specified by:

extendLock in interface RecordStore

unlock

public boolean unlock(Data key,
                      String caller,
                      long threadId)

Specified by:

unlock in interface RecordStore

forceUnlock

public boolean forceUnlock(Data dataKey)

Specified by:

forceUnlock in interface RecordStore

getHeapCost

public long getHeapCost()

Specified by:

getHeapCost in interface RecordStore

isLocked

public boolean isLocked(Data dataKey)

Specified by:

isLocked in interface RecordStore

isLockedBy

public boolean isLockedBy(Data key,
                          String caller,
                          long threadId)

Specified by:

isLockedBy in interface RecordStore

canAcquireLock

public boolean canAcquireLock(Data key,
                              String caller,
                              long threadId)

Specified by:

canAcquireLock in interface RecordStore

getLockOwnerInfo

public String getLockOwnerInfo(Data key)

Specified by:

getLockOwnerInfo in interface RecordStore

entrySetObject

public Set<Map.Entry<Data,Object>> entrySetObject()

Specified by:

entrySetObject in interface RecordStore

entrySetData

public Set<Map.Entry<Data,Data>> entrySetData()

Specified by:

entrySetData in interface RecordStore

getMapEntry

public Map.Entry<Data,Object> getMapEntry(Data dataKey)

Specified by:

getMapEntry in interface RecordStore

getMapEntryForBackup

public Map.Entry<Data,Object> getMapEntryForBackup(Data dataKey)

Specified by:

getMapEntryForBackup in interface RecordStore

keySet

public Set<Data> keySet()

Specified by:

keySet in interface RecordStore

valuesObject

public Collection<Object> valuesObject()

Specified by:

valuesObject in interface RecordStore

valuesData

public Collection<Data> valuesData()

Specified by:

valuesData in interface RecordStore

clear

public void clear()

Specified by:

clear in interface RecordStore

reset

public void reset()

Specified by:

reset in interface RecordStore

remove

public Object remove(Data dataKey)

Specified by:

remove in interface RecordStore

evict

public Object evict(Data dataKey)

Specified by:

evict in interface RecordStore

remove

public boolean remove(Data dataKey,
                      Object testValue)

Specified by:

remove in interface RecordStore

get

public Object get(Data dataKey)

Specified by:

get in interface RecordStore

getAll

public MapEntrySet getAll(Set<Data> keySet)

Specified by:

getAll in interface RecordStore

containsKey

public boolean containsKey(Data dataKey)

Specified by:

containsKey in interface RecordStore

put

public void put(Map.Entry<Data,Object> entry)

Specified by:

put in interface RecordStore

put

public Object put(Data dataKey,
                  Object value,
                  long ttl)

Specified by:

put in interface RecordStore

set

public boolean set(Data dataKey,
                   Object value,
                   long ttl)

Specified by:

set in interface RecordStore

merge

public boolean merge(Data dataKey,
                     EntryView mergingEntry,
                     MapMergePolicy mergePolicy)

Specified by:

merge in interface RecordStore

replace

public Object replace(Data dataKey,
                      Object value)

Specified by:

replace in interface RecordStore

replace

public boolean replace(Data dataKey,
                       Object testValue,
                       Object newValue)

Specified by:

replace in interface RecordStore

putTransient

public void putTransient(Data dataKey,
                         Object value,
                         long ttl)

Specified by:

putTransient in interface RecordStore

putFromLoad

public void putFromLoad(Data dataKey,
                        Object value,
                        long ttl)

Specified by:

putFromLoad in interface RecordStore

tryPut

public boolean tryPut(Data dataKey,
                      Object value,
                      long ttl)

Specified by:

tryPut in interface RecordStore

putIfAbsent

public Object putIfAbsent(Data dataKey,
                          Object value,
                          long ttl)

Specified by:

putIfAbsent in interface RecordStore

getSizeEstimator

public SizeEstimator getSizeEstimator()

Specified by:

getSizeEstimator in interface RecordStore