public class DefaultAccumulatorInfoSupplier extends Object implements AccumulatorInfoSupplier
AccumulatorInfoSupplier
.
At most one thread can write to this class at a time.AccumulatorInfoSupplier
Constructor and Description |
---|
DefaultAccumulatorInfoSupplier() |
Modifier and Type | Method and Description |
---|---|
int |
accumulatorInfoCountOfMap(String mapName) |
AccumulatorInfo |
getAccumulatorInfoOrNull(String mapName,
String cacheId)
Returns
AccumulatorInfo for cache of maIMap p. |
ConcurrentMap<String,ConcurrentMap<String,AccumulatorInfo>> |
getAll() |
void |
putIfAbsent(String mapName,
String cacheId,
AccumulatorInfo info)
Adds a new
AccumulatorInfo for the query-cache of IMap . |
void |
remove(String mapName,
String cacheId)
Removes
AccumulatorInfo from this supplier. |
public AccumulatorInfo getAccumulatorInfoOrNull(String mapName, String cacheId)
AccumulatorInfoSupplier
AccumulatorInfo
for cache of maIMap
p.getAccumulatorInfoOrNull
in interface AccumulatorInfoSupplier
mapName
- map name.cacheId
- cache name.AccumulatorInfo
for cache of map.public void putIfAbsent(String mapName, String cacheId, AccumulatorInfo info)
AccumulatorInfoSupplier
AccumulatorInfo
for the query-cache of IMap
.putIfAbsent
in interface AccumulatorInfoSupplier
mapName
- map name.cacheId
- cache name.public void remove(String mapName, String cacheId)
AccumulatorInfoSupplier
AccumulatorInfo
from this supplier.remove
in interface AccumulatorInfoSupplier
mapName
- map name.cacheId
- cache name.public ConcurrentMap<String,ConcurrentMap<String,AccumulatorInfo>> getAll()
getAll
in interface AccumulatorInfoSupplier
AccumulatorInfo
of all QueryCache
by map namepublic int accumulatorInfoCountOfMap(String mapName)
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.