public class SubscriberAccumulator extends BasicAccumulator<QueryCacheEventData>
QueryCache
. Otherwise, it informs registered callback if there is
any.
This class can be accessed by multiple-threads at a time.Modifier and Type | Field and Description |
---|---|
protected CyclicBuffer<E> |
buffer |
protected QueryCacheContext |
context |
protected AccumulatorInfo |
info |
protected PartitionSequencer |
partitionSequencer |
handler, logger
Modifier | Constructor and Description |
---|---|
protected |
SubscriberAccumulator(QueryCacheContext context,
AccumulatorInfo info) |
Modifier and Type | Method and Description |
---|---|
void |
accumulate(QueryCacheEventData event)
Adds event to this accumulator.
|
protected AccumulatorHandler<QueryCacheEventData> |
createAccumulatorHandler(QueryCacheContext context,
AccumulatorInfo info) |
CyclicBuffer<E> |
getBuffer() |
protected QueryCacheContext |
getContext() |
protected long |
getNow() |
protected boolean |
isExpired(QueryCacheEventData entry,
long delayMillis,
long now) |
protected boolean |
isNextEvent(Sequenced event) |
void |
reset()
Resets this accumulator.
|
createAccumulatorProcessor, getInfo, isEmpty, iterator, poll, poll, setHead, size
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEach, spliterator
protected final AccumulatorInfo info
protected final QueryCacheContext context
protected final CyclicBuffer<E extends Sequenced> buffer
protected final PartitionSequencer partitionSequencer
protected SubscriberAccumulator(QueryCacheContext context, AccumulatorInfo info)
public void reset()
Accumulator
reset
in interface Accumulator<QueryCacheEventData>
reset
in class BasicAccumulator<QueryCacheEventData>
public void accumulate(QueryCacheEventData event)
Accumulator
accumulate
in interface Accumulator<QueryCacheEventData>
accumulate
in class BasicAccumulator<QueryCacheEventData>
event
- event to add.protected boolean isNextEvent(Sequenced event)
protected AccumulatorHandler<QueryCacheEventData> createAccumulatorHandler(QueryCacheContext context, AccumulatorInfo info)
createAccumulatorHandler
in class BasicAccumulator<QueryCacheEventData>
public CyclicBuffer<E> getBuffer()
protected QueryCacheContext getContext()
protected long getNow()
protected boolean isExpired(QueryCacheEventData entry, long delayMillis, long now)
Copyright © 2020 Hazelcast, Inc.. All Rights Reserved.