public class PublisherAccumulatorHandler extends Object implements AccumulatorHandler<Sequenced>
Accumulator
.
Processing is done by the help of AccumulatorProcessor
.EventPublisherAccumulatorProcessor
Constructor and Description |
---|
PublisherAccumulatorHandler(QueryCacheContext context,
AccumulatorProcessor<Sequenced> processor) |
Modifier and Type | Method and Description |
---|---|
void |
handle(Sequenced eventData,
boolean lastElement)
Handles element.
|
void |
reset()
Resets this handler to its initial state.
|
public PublisherAccumulatorHandler(QueryCacheContext context, AccumulatorProcessor<Sequenced> processor)
public void handle(Sequenced eventData, boolean lastElement)
AccumulatorHandler
handle
in interface AccumulatorHandler<Sequenced>
eventData
- the element to be processed.lastElement
- true
if this is the last element
got from the Accumulator
, otherwise false
.public void reset()
AccumulatorHandler
reset
in interface AccumulatorHandler<Sequenced>
Copyright © 2020 Hazelcast, Inc.. All Rights Reserved.