com.hazelcast.map.impl.querycache.subscriber

Class SubscriberAccumulator

java.lang.Object

com.hazelcast.map.impl.querycache.accumulator.BasicAccumulator<QueryCacheEventData>

com.hazelcast.map.impl.querycache.subscriber.SubscriberAccumulator

All Implemented Interfaces:

Accumulator<QueryCacheEventData>, Iterable<QueryCacheEventData>

public class SubscriberAccumulator
extends BasicAccumulator<QueryCacheEventData>

If all incoming events are in the correct sequence order, this accumulator applies those events to QueryCache. Otherwise, it informs registered callback if there is any.

This class can be accessed by multiple-threads at a time.

Field Summary

Fields

Modifier and Type	Field and Description
protected CyclicBuffer<E>	buffer
protected QueryCacheContext	context
protected AccumulatorInfo	info
protected PartitionSequencer	partitionSequencer

Fields inherited from class com.hazelcast.map.impl.querycache.accumulator.BasicAccumulator

logger

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SubscriberAccumulator(QueryCacheContext context, AccumulatorInfo info)

Method Summary

Modifier and Type	Method and Description
void	accumulate(QueryCacheEventData event) Adds event to this accumulator.
protected SubscriberSequencerProvider	createSequencerProvider()
ConcurrentMap<Integer,Long>	getBrokenSequences()
CyclicBuffer<E>	getBuffer()
protected QueryCacheContext	getContext()
protected long	getNow()
boolean	isEndEvent(QueryCacheEventData event)
protected boolean	isExpired(QueryCacheEventData entry, long delayMillis, long now)
protected boolean	isNextEvent(Sequenced event)

Methods inherited from class com.hazelcast.map.impl.querycache.accumulator.BasicAccumulator

createAccumulatorProcessor, getInfo, isEmpty, iterator, poll, poll, reset, setHead, size

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

info

protected final AccumulatorInfo info

context

protected final QueryCacheContext context

buffer

protected final CyclicBuffer<E extends Sequenced> buffer

partitionSequencer

protected final PartitionSequencer partitionSequencer

Constructor Detail

SubscriberAccumulator

protected SubscriberAccumulator(QueryCacheContext context,
                                AccumulatorInfo info)

Method Detail

accumulate

public void accumulate(QueryCacheEventData event)

Description copied from interface: Accumulator

Adds event to this accumulator.

Specified by:

accumulate in interface Accumulator<QueryCacheEventData>

Overrides:

accumulate in class BasicAccumulator<QueryCacheEventData>

Parameters:

event - event to add.

isNextEvent

protected boolean isNextEvent(Sequenced event)

createSequencerProvider

protected SubscriberSequencerProvider createSequencerProvider()

getBrokenSequences

public ConcurrentMap<Integer,Long> getBrokenSequences()

isEndEvent

public boolean isEndEvent(QueryCacheEventData event)

getBuffer

public CyclicBuffer<E> getBuffer()

getContext

protected QueryCacheContext getContext()

getNow

protected long getNow()

isExpired

protected boolean isExpired(QueryCacheEventData entry,
                            long delayMillis,
                            long now)