com.hazelcast.map.impl.querycache.publisher

Class AccumulatorSweeper

java.lang.Object

com.hazelcast.map.impl.querycache.publisher.AccumulatorSweeper

public final class AccumulatorSweeper
extends Object

Responsible for sweeping all registered accumulators of a PublisherContext. This is needed in situations like ownership changes/graceful shutdown.

Method Summary

Modifier and Type	Method and Description
static void	flushAccumulator(PublisherContext publisherContext, int partitionId)
static void	flushAllAccumulators(PublisherContext publisherContext)
static void	removeAccumulator(PublisherContext publisherContext, int partitionId)

Methods inherited from class java.lang.Object

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

Method Detail

flushAllAccumulators

public static void flushAllAccumulators(PublisherContext publisherContext)

flushAccumulator

public static void flushAccumulator(PublisherContext publisherContext,
                                    int partitionId)

removeAccumulator

public static void removeAccumulator(PublisherContext publisherContext,
                                     int partitionId)