public class AccumulatorScannerTask extends Object implements Runnable
Accumulator
instances of all QueryCache
s on this node.
If it finds any event that needs to be published in an accumulator, it creates and sends
ConsumeAccumulatorOperation
to relevant partitions.
ConsumeAccumulatorOperation
Constructor and Description |
---|
AccumulatorScannerTask(QueryCacheContext context) |
public AccumulatorScannerTask(QueryCacheContext context)
Copyright © 2019 Hazelcast, Inc.. All rights reserved.