K
- key type for map data storeV
- value type for map data storepublic abstract class AbstractMapDataStore<K,V> extends Object implements MapDataStore<K,V>
Modifier and Type | Field and Description |
---|---|
protected NodeEngine |
nodeEngine |
Modifier | Constructor and Description |
---|---|
protected |
AbstractMapDataStore(MapStoreContext mapStoreContext) |
Modifier and Type | Method and Description |
---|---|
MapStoreWrapper |
getStore() |
TxnReservedCapacityCounter |
getTxnReservedCapacityCounter() |
protected long |
getUserExpirationTime(long hzExpirationTime)
Returns expiration time offset in terms of JVM clock.
|
boolean |
isPostProcessingMapStore() |
boolean |
isWithExpirationTime() |
Map |
loadAll(Collection keys)
Loads values for the provided keys if a
MapLoader is
configured for this map. |
void |
removeAll(Collection keys)
Removes keys from map store.
|
protected Data |
toHeapData(Object obj) |
protected Object |
toObject(Object obj) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
add, addBackup, addForcibly, addTransient, flush, hardFlush, load, loadable, notFinishedOperationsCount, remove, removeBackup, reset, softFlush
protected final NodeEngine nodeEngine
protected AbstractMapDataStore(MapStoreContext mapStoreContext)
public Map loadAll(Collection keys)
MapDataStore
MapLoader
is
configured for this map. This method never returns null
.
The returned map will contain deserialised keys and values.loadAll
in interface MapDataStore<K,V>
keys
- the keys for which values are loadedMapLoader.loadAll(Collection)
public void removeAll(Collection keys)
Data
to object conversions of keys.
Directly removes keys from map store as in write-through mode.
It works same for write-behind and write-through stores.removeAll
in interface MapDataStore<K,V>
keys
- to be removedprotected long getUserExpirationTime(long hzExpirationTime)
hzExpirationTime
- public MapStoreWrapper getStore()
public boolean isPostProcessingMapStore()
isPostProcessingMapStore
in interface MapDataStore<K,V>
public boolean isWithExpirationTime()
isWithExpirationTime
in interface MapDataStore<K,V>
public TxnReservedCapacityCounter getTxnReservedCapacityCounter()
getTxnReservedCapacityCounter
in interface MapDataStore<K,V>
Copyright © 2019 Hazelcast, Inc.. All rights reserved.