public final class AccumulatorSweeper extends Object
PublisherContext
.
This is needed in situations like ownership changes/graceful shutdown.Modifier and Type | Field and Description |
---|---|
static long |
END_SEQUENCE |
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) |
public static final long END_SEQUENCE
public static void flushAllAccumulators(PublisherContext publisherContext)
public static void flushAccumulator(PublisherContext publisherContext, int partitionId)
public static void sendEndOfSequenceEvents(PublisherContext publisherContext, int partitionId)
public static void removeAccumulator(PublisherContext publisherContext, int partitionId)
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.