com.hazelcast.map.impl.querycache.publisher

Class CoalescingPublisherAccumulator

java.lang.Object

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

com.hazelcast.map.impl.querycache.publisher.CoalescingPublisherAccumulator

All Implemented Interfaces:

Accumulator<QueryCacheEventData>, Iterable<QueryCacheEventData>

public class CoalescingPublisherAccumulator
extends BasicAccumulator<QueryCacheEventData>

Accumulator which coalesces keys during accumulation.

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

handler, logger

Constructor Summary

Constructors

Constructor and Description
CoalescingPublisherAccumulator(QueryCacheContext context, AccumulatorInfo info)

Method Summary

Modifier and Type	Method and Description
void	accumulate(QueryCacheEventData eventData) Adds event to this accumulator.
protected AccumulatorProcessor	createAccumulatorProcessor(AccumulatorInfo info, QueryCacheEventService eventService)
CyclicBuffer<E>	getBuffer()
protected QueryCacheContext	getContext()
protected long	getNow()
protected boolean	isExpired(QueryCacheEventData entry, long delayMillis, long now)

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

getInfo, getPartitionSequencer, isEmpty, iterator, peek, 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

CoalescingPublisherAccumulator

public CoalescingPublisherAccumulator(QueryCacheContext context,
                                      AccumulatorInfo info)

Method Detail

accumulate

public void accumulate(QueryCacheEventData eventData)

Description copied from interface: Accumulator

Adds event to this accumulator.

Specified by:

accumulate in interface Accumulator<QueryCacheEventData>

Overrides:

accumulate in class BasicAccumulator<QueryCacheEventData>

Parameters:

eventData - event to add.

createAccumulatorProcessor

protected AccumulatorProcessor createAccumulatorProcessor(AccumulatorInfo info,
                                                          QueryCacheEventService eventService)

Overrides:

createAccumulatorProcessor in class BasicAccumulator<QueryCacheEventData>

getBuffer

public CyclicBuffer<E> getBuffer()

getContext

protected QueryCacheContext getContext()

getNow

protected long getNow()

isExpired

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