K
- type of key to storeV
- type of value to storepublic interface MapDataStore<K,V>
Modifier and Type | Method and Description |
---|---|
V |
add(K key,
V value,
long expirationTime,
long now,
UUID transactionId) |
V |
addBackup(K key,
V value,
long expirationTime,
long now,
UUID transactionId) |
void |
addForcibly(DelayedEntry<Data,Object> delayedEntry)
Adds delayed-entry without doing capacity checks.
|
void |
addTransient(K key,
long now) |
V |
flush(K key,
V value,
boolean backup)
Flushes the supplied key to the map-store.
|
TxnReservedCapacityCounter |
getTxnReservedCapacityCounter() |
void |
hardFlush()
Flushes write-behind-queue into map-store in calling thread.
|
boolean |
isPostProcessingMapStore() |
boolean |
isWithExpirationTime() |
V |
load(K key) |
boolean |
loadable(K key)
Used in
IMap.loadAll(boolean) calls. |
Map |
loadAll(Collection keys)
Loads values for the provided keys if a
MapLoader is
configured for this map. |
int |
notFinishedOperationsCount() |
void |
remove(K key,
long now,
UUID transactionId) |
void |
removeAll(Collection keys)
Removes keys from map store.
|
void |
removeBackup(K key,
long now,
UUID transactionId) |
void |
reset()
Returns all associated resources of this
map-data-store back to the initial state.
|
long |
softFlush()
Only marks this
MapDataStore as flush-able. |
void addForcibly(DelayedEntry<Data,Object> delayedEntry)
void addTransient(K key, long now)
void reset()
Map loadAll(Collection keys)
MapLoader
is
configured for this map. This method never returns null
.
The returned map will contain deserialised keys and values.keys
- the keys for which values are loadedkeys
- the keys for which values are loadedMapLoader.loadAll(Collection)
void removeAll(Collection keys)
Data
to object conversions of keys.keys
- to be removedboolean loadable(K key)
IMap.loadAll(boolean)
calls. If the
write-behind map-store feature is enabled, some
things may lead to possible data inconsistencies.
These are:
- calling evict/evictAll,
- calling remove, and
- not yet stored write-behind queue operations.
With this method, we can be sure if a key can be loadable from map-store or not.
key
- the key to query whether it is loadable or nottrue
if the key is loadableint notFinishedOperationsCount()
boolean isPostProcessingMapStore()
long softFlush()
MapDataStore
as flush-able. Flush
means storing entries from write-behind-queue into map-store
regardless of the scheduled store-time. Actual flushing is done
by another thread than partition-operation thread which runs
StoreWorker
.MapFlushOperation
void hardFlush()
After calling of this method, all elements in the WriteBehindQueue
of this MapDataStore
should be in
map-store regardless of the scheduled store-time.
The only call to this method is in node-shutdown.
MapManagedService.shutdown(boolean)
V flush(K key, V value, boolean backup)
key
- key to be flushedvalue
- value to be flushedbackup
- true
calling this method for
backup partition, false
for owner partition.boolean isWithExpirationTime()
TxnReservedCapacityCounter getTxnReservedCapacityCounter()
Copyright © 2019 Hazelcast, Inc.. All rights reserved.