com.hazelcast.map.impl.querycache.accumulator

Class BasicAccumulator<E extends Sequenced>

java.lang.Object

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

Type Parameters:

E - the type which will be accumulated in this Accumulator.

All Implemented Interfaces:

Accumulator<E>, Iterable<E>

Direct Known Subclasses:

SubscriberAccumulator

public class BasicAccumulator<E extends Sequenced>
extends Object

This class implements basic functionality of an Accumulator. Subclasses should override required methods according to their context.

See Also:

NonStopPublisherAccumulator, BatchPublisherAccumulator

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	accumulate(E event) Adds event to this accumulator.
protected AccumulatorHandler<E>	createAccumulatorHandler(QueryCacheContext context, AccumulatorInfo info)
protected AccumulatorProcessor<Sequenced>	createAccumulatorProcessor(AccumulatorInfo info, QueryCacheEventService eventService)
CyclicBuffer<E>	getBuffer()
protected QueryCacheContext	getContext()
AccumulatorInfo	getInfo() Returns AccumulatorInfo of this accumulator.
protected long	getNow()
boolean	isEmpty() Returns true if this accumulator contains no elements.
protected boolean	isExpired(QueryCacheEventData entry, long delayMillis, long now)
Iterator<E>	iterator() Returns an iterator over the items in this accumulator in proper sequence.
int	poll(AccumulatorHandler<E> handler, int maxItems) Reads this accumulator if it contains at least maxItems, otherwise do not read anything.
int	poll(AccumulatorHandler<E> handler, long delay, TimeUnit unit) Reads all expired items to the supplied handler.
void	reset() Resets this accumulator.
boolean	setHead(long sequence) Tries to set head of this accumulator to the supplied sequence and returns true, if that sequence is still exist in this accumulator.
int	size() Current size of accumulator.

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

handler

protected final AccumulatorHandler<E extends Sequenced> handler

logger

protected final ILogger logger

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

BasicAccumulator

protected BasicAccumulator(QueryCacheContext context,
                           AccumulatorInfo info)

Method Detail

accumulate

public void accumulate(E event)

Description copied from interface: Accumulator

Adds event to this accumulator.

Parameters:

event - event to add.

poll

public int poll(AccumulatorHandler<E> handler,
                int maxItems)

Description copied from interface: Accumulator

Reads this accumulator if it contains at least maxItems, otherwise do not read anything. If this method adds items to the supplied handler, head of this accumulator advances. Used for batching purposes.

Parameters:

handler - handler to process this accumulator.

maxItems - read this accumulator if it contains at least maxItems

Returns:

the number of elements read.

poll

public int poll(AccumulatorHandler<E> handler,
                long delay,
                TimeUnit unit)

Description copied from interface: Accumulator

Reads all expired items to the supplied handler. If this method adds items to the supplied handler, head of this accumulator advances.

Parameters:

handler - handler to process this accumulator.

delay - after this duration element will be poll-able.

unit - time-unit

Returns:

the number of elements polled.

iterator

public Iterator<E> iterator()

Description copied from interface: Accumulator

Returns an iterator over the items in this accumulator in proper sequence. Also this methods advances head of this accumulator.

Returns:

an iterator over the items in this list accumulator in proper sequence.

size

public int size()

Description copied from interface: Accumulator

Current size of accumulator.

Returns:

returns current size of accumulator.

isEmpty

public boolean isEmpty()

Description copied from interface: Accumulator

Returns true if this accumulator contains no elements.

Returns:

true if this accumulator contains no elements

getInfo

public AccumulatorInfo getInfo()

Description copied from interface: Accumulator

Returns AccumulatorInfo of this accumulator.

Returns:

AccumulatorInfo of this accumulator.

setHead

public boolean setHead(long sequence)

Description copied from interface: Accumulator

Tries to set head of this accumulator to the supplied sequence and returns true, if that sequence is still exist in this accumulator. Otherwise, returns false.

Parameters:

sequence - the sequence number which will be the head of this accumulator.

Returns:

true if sequence is set, otherwise returns false

reset

public void reset()

Description copied from interface: Accumulator

Resets this accumulator. After return of this call, accumulator will be in its initial state.

Specified by:

reset in interface Accumulator<E extends Sequenced>

createAccumulatorHandler

protected AccumulatorHandler<E> createAccumulatorHandler(QueryCacheContext context,
                                                         AccumulatorInfo info)

createAccumulatorProcessor

protected AccumulatorProcessor<Sequenced> createAccumulatorProcessor(AccumulatorInfo info,
                                                                     QueryCacheEventService eventService)

getBuffer

public CyclicBuffer<E> getBuffer()

getContext

protected QueryCacheContext getContext()

getNow

protected long getNow()

isExpired

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