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 now) |
V |
addBackup(K key,
V value,
long now) |
void |
addTransient(K key,
long now) |
V |
flush(K key,
V value,
boolean backup)
Flushes the supplied key to the map-store.
|
void |
hardFlush()
Flushes write-behind-queue into map-store in calling thread.
|
boolean |
isPostProcessingMapStore() |
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) |
void |
removeAll(Collection keys)
Removes keys from map store.
|
void |
removeBackup(K key,
long now) |
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 addTransient(K key, long now)
void remove(K key, long now)
void removeBackup(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 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()
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)
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.