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.

Field Summary

Fields

Modifier and Type	Field and Description
static long	END_SEQUENCE

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)
static void	sendEndOfSequenceEvents(PublisherContext publisherContext, int partitionId)

Methods inherited from class java.lang.Object

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

Field Detail

END_SEQUENCE

public static final long END_SEQUENCE

See Also:

Constant Field Values

Method Detail

flushAllAccumulators

public static void flushAllAccumulators(PublisherContext publisherContext)

flushAccumulator

public static void flushAccumulator(PublisherContext publisherContext,
                                    int partitionId)

sendEndOfSequenceEvents

public static void sendEndOfSequenceEvents(PublisherContext publisherContext,
                                           int partitionId)

removeAccumulator

public static void removeAccumulator(PublisherContext publisherContext,
                                     int partitionId)