public class DefaultRecordStore extends Object implements RecordStore
Constructor and Description |
---|
DefaultRecordStore(String name,
MapService mapService,
int partitionId) |
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() |
public DefaultRecordStore(String name, MapService mapService, int partitionId)
public boolean isLoaded()
isLoaded
in interface RecordStore
public void setLoaded(boolean isLoaded)
setLoaded
in interface RecordStore
public void checkIfLoaded()
checkIfLoaded
in interface RecordStore
public String getName()
getName
in interface RecordStore
public void flush()
flush
in interface RecordStore
public MapContainer getMapContainer()
getMapContainer
in interface RecordStore
public Record getRecord(Data key)
getRecord
in interface RecordStore
public void putRecord(Data key, Record record)
putRecord
in interface RecordStore
public Record putBackup(Data key, Object value)
putBackup
in interface RecordStore
public Record putBackup(Data key, Object value, long ttl, boolean shouldSchedule)
putBackup
in interface RecordStore
public void deleteRecord(Data key)
deleteRecord
in interface RecordStore
public Map<Data,Record> getReadonlyRecordMap()
getReadonlyRecordMap
in interface RecordStore
public void clearPartition()
clearPartition
in interface RecordStore
public int size()
size
in interface RecordStore
public boolean isEmpty()
isEmpty
in interface RecordStore
public boolean containsValue(Object value)
containsValue
in interface RecordStore
public boolean lock(Data key, String caller, long threadId, long ttl)
lock
in interface RecordStore
public boolean txnLock(Data key, String caller, long threadId, long ttl)
txnLock
in interface RecordStore
public boolean extendLock(Data key, String caller, long threadId, long ttl)
extendLock
in interface RecordStore
public boolean unlock(Data key, String caller, long threadId)
unlock
in interface RecordStore
public boolean forceUnlock(Data dataKey)
forceUnlock
in interface RecordStore
public long getHeapCost()
getHeapCost
in interface RecordStore
public boolean isLocked(Data dataKey)
isLocked
in interface RecordStore
public boolean isLockedBy(Data key, String caller, long threadId)
isLockedBy
in interface RecordStore
public boolean canAcquireLock(Data key, String caller, long threadId)
canAcquireLock
in interface RecordStore
public String getLockOwnerInfo(Data key)
getLockOwnerInfo
in interface RecordStore
public Set<Map.Entry<Data,Object>> entrySetObject()
entrySetObject
in interface RecordStore
public Set<Map.Entry<Data,Data>> entrySetData()
entrySetData
in interface RecordStore
public Map.Entry<Data,Object> getMapEntry(Data dataKey)
getMapEntry
in interface RecordStore
public Map.Entry<Data,Object> getMapEntryForBackup(Data dataKey)
getMapEntryForBackup
in interface RecordStore
public Set<Data> keySet()
keySet
in interface RecordStore
public Collection<Object> valuesObject()
valuesObject
in interface RecordStore
public Collection<Data> valuesData()
valuesData
in interface RecordStore
public void clear()
clear
in interface RecordStore
public void reset()
reset
in interface RecordStore
public Object remove(Data dataKey)
remove
in interface RecordStore
public Object evict(Data dataKey)
evict
in interface RecordStore
public boolean remove(Data dataKey, Object testValue)
remove
in interface RecordStore
public Object get(Data dataKey)
get
in interface RecordStore
public MapEntrySet getAll(Set<Data> keySet)
getAll
in interface RecordStore
public boolean containsKey(Data dataKey)
containsKey
in interface RecordStore
public void put(Map.Entry<Data,Object> entry)
put
in interface RecordStore
public Object put(Data dataKey, Object value, long ttl)
put
in interface RecordStore
public boolean set(Data dataKey, Object value, long ttl)
set
in interface RecordStore
public boolean merge(Data dataKey, EntryView mergingEntry, MapMergePolicy mergePolicy)
merge
in interface RecordStore
public Object replace(Data dataKey, Object value)
replace
in interface RecordStore
public boolean replace(Data dataKey, Object testValue, Object newValue)
replace
in interface RecordStore
public void putTransient(Data dataKey, Object value, long ttl)
putTransient
in interface RecordStore
public void putFromLoad(Data dataKey, Object value, long ttl)
putFromLoad
in interface RecordStore
public boolean tryPut(Data dataKey, Object value, long ttl)
tryPut
in interface RecordStore
public Object putIfAbsent(Data dataKey, Object value, long ttl)
putIfAbsent
in interface RecordStore
public SizeEstimator getSizeEstimator()
getSizeEstimator
in interface RecordStore
Copyright © 2014 Hazelcast, Inc.. All rights reserved.