com.hazelcast.map.impl
public interface RecordStore
Modifier and Type | Method and Description |
---|---|
boolean |
canAcquireLock(Data key,
String caller,
long threadId) |
void |
checkIfLoaded() |
int |
clear() |
void |
clearPartition() |
boolean |
containsKey(Data dataKey) |
boolean |
containsValue(Object testValue) |
boolean |
delete(Data dataKey) |
Set<Map.Entry<Data,Data>> |
entrySetData() |
Object |
evict(Data key,
boolean backup) |
int |
evictAll(boolean backup)
Evicts all keys except locked ones.
|
void |
evictEntries(long now,
boolean backup) |
void |
evictExpiredEntries(int percentage,
boolean backup)
Do expiration operations.
|
boolean |
extendLock(Data key,
String caller,
long threadId,
long ttl) |
void |
flush() |
boolean |
forceUnlock(Data dataKey) |
Object |
get(Data dataKey,
boolean backup)
Gets record from
RecordStore . |
MapEntrySet |
getAll(Set<Data> keySet) |
long |
getHeapCost() |
String |
getLockOwnerInfo(Data key) |
MapContainer |
getMapContainer() |
MapDataStore<Data,Object> |
getMapDataStore() |
Map.Entry<Data,Object> |
getMapEntry(Data dataKey,
long now) |
String |
getName() |
int |
getPartitionId() |
Record |
getRecord(Data key) |
Map<Data,Record> |
getRecordMap()
Returns records map.
|
Record |
getRecordOrNull(Data key)
Returns live record or null if record is already expired.
|
boolean |
isEmpty() |
boolean |
isExpirable() |
boolean |
isLoaded() |
boolean |
isLocked(Data key) |
boolean |
isTransactionallyLocked(Data key) |
Iterator<Record> |
iterator()
Iterates over record store values.
|
Iterator<Record> |
iterator(long now,
boolean backup)
Iterates over record store values by respecting expiration.
|
Set<Data> |
keySet() |
void |
loadAll(boolean replaceExistingValues)
Loads all keys and values
|
void |
loadAllFromStore(List<Data> keys,
boolean replaceExistingValues)
Loads all given keys from defined map store.
|
Iterator<Record> |
loadAwareIterator(long now,
boolean backup)
Iterates over record store values but first waits map store to load.
|
void |
maybeDoInitialLoad()
Performs initial loading from a MapLoader if it has not been done before
|
boolean |
merge(Data dataKey,
EntryView mergingEntryView,
MapMergePolicy mergePolicy) |
Object |
put(Data dataKey,
Object dataValue,
long ttl) |
void |
put(Map.Entry<Data,Object> entry) |
Record |
putBackup(Data key,
Object value) |
Record |
putBackup(Data key,
Object value,
long ttl,
boolean putTransient) |
Object |
putFromLoad(Data key,
Object value)
Puts key-value pair to map which is the result of a load from map store operation.
|
Object |
putFromLoad(Data key,
Object value,
long ttl)
Puts key-value pair to map which is the result of a load from map store operation.
|
Object |
putIfAbsent(Data dataKey,
Object value,
long ttl) |
void |
putRecord(Data key,
Record record)
Puts a data key and a record value to record-store.
|
void |
putTransient(Data dataKey,
Object value,
long ttl) |
Data |
readBackupData(Data key)
Called when
MapConfig.isReadBackupData() is true from
MapProxySupport.getInternal(com.hazelcast.nio.serialization.Data)
Returns corresponding value for key as Data . |
Object |
remove(Data dataKey) |
boolean |
remove(Data dataKey,
Object testValue) |
void |
removeBackup(Data dataKey)
Similar to
remove(com.hazelcast.nio.serialization.Data)
except removeBackup doesn't touch mapstore since it does not return previous value. |
Object |
replace(Data dataKey,
Object update) |
boolean |
replace(Data dataKey,
Object expect,
Object update)
Sets the value to the given updated value
if
RecordFactory.isEquals(java.lang.Object, java.lang.Object) comparison
of current value and expected value is true . |
void |
reset()
Resets the record store to it's initial state.
|
boolean |
set(Data dataKey,
Object value,
long ttl) |
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) |
void |
updateLoadStatus(boolean lastBatch,
Throwable exception) |
Collection<Data> |
valuesData() |
String getName()
Record putBackup(Data key, Object value, long ttl, boolean putTransient)
key
- the key to be processed.value
- the value to be processed.ttl
- milliseconds. Check out MapProxySupport.putInternal(com.hazelcast.nio.serialization.Data, com.hazelcast.nio.serialization.Data, long, java.util.concurrent.TimeUnit)
putTransient
- true
if putting transient entry, otherwise false
boolean delete(Data dataKey)
void removeBackup(Data dataKey)
remove(com.hazelcast.nio.serialization.Data)
except removeBackup doesn't touch mapstore since it does not return previous value.Object get(Data dataKey, boolean backup)
RecordStore
.
Loads missing keys from map store.dataKey
- key.backup
- true
if a backup partition, otherwise false
.RecordStore
Data readBackupData(Data key)
MapConfig.isReadBackupData()
is true
from
MapProxySupport.getInternal(com.hazelcast.nio.serialization.Data)
Returns corresponding value for key as Data
.
This adds an extra serialization step. For the reason of this behaviour please see issue 1292 on github.key
- key to be accessedData
independent of InMemoryFormat
MapEntrySet getAll(Set<Data> keySet)
boolean containsKey(Data dataKey)
boolean replace(Data dataKey, Object expect, Object update)
RecordFactory.isEquals(java.lang.Object, java.lang.Object)
comparison
of current value and expected value is true
.dataKey
- key which's value is requested to be replaced.expect
- the expected valueupdate
- the new valuetrue
if successful. False return indicates that
the actual value was not equal to the expected value.Object putFromLoad(Data key, Object value)
key
- key to put.value
- to put.PutFromLoadAllOperation
Object putFromLoad(Data key, Object value, long ttl)
key
- key to put.value
- to put.ttl
- time to live seconds.PutAllOperation
boolean merge(Data dataKey, EntryView mergingEntryView, MapMergePolicy mergePolicy)
void putRecord(Data key, Record record)
key
- the data key to put record store.record
- the value for record store.MapReplicationOperation
Iterator<Record> iterator()
Iterator<Record> iterator(long now, boolean backup)
Iterator<Record> loadAwareIterator(long now, boolean backup)
IMap.keySet(com.hazelcast.query.Predicate)
,
this method can be used to return a read-only iterator.now
- current time in millisbackup
- true
if a backup partition, otherwise false
.int size()
boolean isLocked(Data key)
boolean isTransactionallyLocked(Data key)
boolean containsValue(Object testValue)
int evictAll(boolean backup)
backup
- true
if a backup partition, otherwise false
.Collection<Data> valuesData()
MapContainer getMapContainer()
void flush()
void clearPartition()
void reset()
boolean forceUnlock(Data dataKey)
long getHeapCost()
boolean isLoaded()
void checkIfLoaded() throws RetryableHazelcastException
RetryableHazelcastException
int clear()
boolean isEmpty()
void evictExpiredEntries(int percentage, boolean backup)
percentage
- of max expirables according to the record store size.backup
- true
if a backup partition, otherwise false
.boolean isExpirable()
true
if record store has at least one candidate entry
for expiration else return false
.void loadAllFromStore(List<Data> keys, boolean replaceExistingValues)
keys
- keys to be loaded.replaceExistingValues
- true
if need to replace existing values otherwise false
lastBatch
- when keys are sent is batches this indicates the last batch. Used to indicate loading is complete.void updateLoadStatus(boolean lastBatch, Throwable exception)
MapDataStore<Data,Object> getMapDataStore()
int getPartitionId()
Record getRecordOrNull(Data key)
key
- key to be accessedget(com.hazelcast.nio.serialization.Data, boolean)
void evictEntries(long now, boolean backup)
void loadAll(boolean replaceExistingValues)
replaceExistingValues
- true
if need to replace existing values otherwise false
void maybeDoInitialLoad()
Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.