com.hazelcast.map.impl.querycache.accumulator

Class AccumulatorScannerTask

java.lang.Object

com.hazelcast.map.impl.querycache.accumulator.AccumulatorScannerTask

All Implemented Interfaces:

Runnable

public class AccumulatorScannerTask
extends Object
implements Runnable

Task for scanning all Accumulator instances of all QueryCaches on this node.

If it finds any event that needs to be published in an accumulator, it creates and sends AccumulatorConsumerOperation to relevant partitions.

See Also:

AccumulatorConsumerOperation

Constructor Summary

Constructors

Constructor and Description
AccumulatorScannerTask(QueryCacheContext context)

Method Summary

Modifier and Type	Method and Description
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

AccumulatorScannerTask

public AccumulatorScannerTask(QueryCacheContext context)

Method Detail

run

public void run()

Specified by:

run in interface Runnable