com.hazelcast.map.impl.querycache.accumulator

Class DefaultAccumulatorInfoSupplier

java.lang.Object

com.hazelcast.map.impl.querycache.accumulator.DefaultAccumulatorInfoSupplier

All Implemented Interfaces:

AccumulatorInfoSupplier

public class DefaultAccumulatorInfoSupplier
extends Object
implements AccumulatorInfoSupplier

Default implementation of AccumulatorInfoSupplier.

At most one thread can write to this class at a time.

See Also:

AccumulatorInfoSupplier

Constructor Summary

Constructors

Constructor and Description
DefaultAccumulatorInfoSupplier()

Method Summary

Modifier and Type	Method and Description
int	accumulatorInfoCountOfMap(String mapName)
AccumulatorInfo	getAccumulatorInfoOrNull(String mapName, String cacheId) Returns AccumulatorInfo for cache of maIMapp.
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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultAccumulatorInfoSupplier

public DefaultAccumulatorInfoSupplier()

Method Detail

getAccumulatorInfoOrNull

public AccumulatorInfo getAccumulatorInfoOrNull(String mapName,
                                                String cacheId)

Description copied from interface: AccumulatorInfoSupplier

Returns AccumulatorInfo for cache of maIMapp.

Specified by:

getAccumulatorInfoOrNull in interface AccumulatorInfoSupplier

Parameters:

mapName - map name.

cacheId - cache name.

Returns:

AccumulatorInfo for cache of map.

putIfAbsent

public void putIfAbsent(String mapName,
                        String cacheId,
                        AccumulatorInfo info)

Description copied from interface: AccumulatorInfoSupplier

Adds a new AccumulatorInfo for the query-cache of IMap.

Specified by:

putIfAbsent in interface AccumulatorInfoSupplier

Parameters:

mapName - map name.

cacheId - cache name.

remove

public void remove(String mapName,
                   String cacheId)

Description copied from interface: AccumulatorInfoSupplier

Removes AccumulatorInfo from this supplier.

Specified by:

remove in interface AccumulatorInfoSupplier

Parameters:

mapName - map name.

cacheId - cache name.

getAll

public ConcurrentMap<String,ConcurrentMap<String,AccumulatorInfo>> getAll()

Specified by:

getAll in interface AccumulatorInfoSupplier

Returns:

all AccumulatorInfo of all QueryCache by map name

accumulatorInfoCountOfMap

public int accumulatorInfoCountOfMap(String mapName)