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.
ConcurrentMap<Integer,Long>	getBrokenSequences()
CyclicBuffer<E>	getBuffer()
protected QueryCacheContext	getContext()
protected long	getNow()
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

getBrokenSequences

public ConcurrentMap<Integer,Long> getBrokenSequences()

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)

getBuffer

public CyclicBuffer<E> getBuffer()

getContext

protected QueryCacheContext getContext()

getNow

protected long getNow()

isExpired

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