com.espertech.esper.epl.agg.aggregator

Class AggregatorNth

java.lang.Object

com.espertech.esper.epl.agg.aggregator.AggregatorNth

All Implemented Interfaces:

AggregationMethod

Direct Known Subclasses:

AggregatorNthFilter

public class AggregatorNth
extends java.lang.Object
implements AggregationMethod

Aggregator to return the Nth oldest element to enter, with N=1 the most recent value is returned. If N is larger than the enter minus leave size, null is returned. A maximum N historical values are stored, so it can be safely used to compare recent values in large views without incurring excessive overhead.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.Object[]	circularBuffer
protected int	currentBufferElementPointer
protected long	numDataPoints
protected int	sizeBuf

Constructor Summary

Constructors

Constructor and Description
AggregatorNth(int sizeBuf) Ctor.

Method Summary

Modifier and Type	Method and Description
static void	applyEnterCodegen(AggregationMethodFactoryNth forge, int column, CodegenMethodNode method, ExprForgeCodegenSymbol symbols, ExprForge[] forges, CodegenClassScope classScope)
static void	applyLeaveCodegen(AggregationMethodFactoryNth forge, int column, CodegenMethodNode method, ExprForgeCodegenSymbol symbols, ExprForge[] forges, CodegenClassScope classScope)
void	clear() Clear out the collection.
static void	clearCodegen(AggregationMethodFactoryNth forge, int column, CodegenMethodNode method)
void	enter(java.lang.Object value) Apply the value as entering aggregation (entering window).
protected void	enterValues(java.lang.Object[] arr)
java.lang.Object[]	getCircularBuffer()
int	getCurrentBufferElementPointer()
long	getNumDataPoints()
int	getSizeBuf()
java.lang.Object	getValue() Returns the current value held.
static void	getValueCodegen(AggregationMethodFactoryNth forge, int column, CodegenMethodNode method)
void	leave(java.lang.Object value) Apply the value as leaving aggregation (leaving window).
static void	rowMemberCodegen(AggregationMethodFactoryNth forge, int column, CodegenCtor ctor, CodegenMembersColumnized membersColumnized)
void	setCircularBuffer(java.lang.Object[] circularBuffer)
void	setCurrentBufferElementPointer(int currentBufferElementPointer)
void	setNumDataPoints(long numDataPoints)

Methods inherited from class java.lang.Object

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

Field Detail

sizeBuf

protected final int sizeBuf

circularBuffer

protected java.lang.Object[] circularBuffer

currentBufferElementPointer

protected int currentBufferElementPointer

numDataPoints

protected long numDataPoints

Constructor Detail

AggregatorNth

public AggregatorNth(int sizeBuf)

Ctor.

Parameters:

sizeBuf - size

Method Detail

rowMemberCodegen

public static void rowMemberCodegen(AggregationMethodFactoryNth forge,
                                    int column,
                                    CodegenCtor ctor,
                                    CodegenMembersColumnized membersColumnized)

enter

public void enter(java.lang.Object value)

Description copied from interface: AggregationMethod

Apply the value as entering aggregation (entering window).

The value can be null since 'null' values may be counted as unique separate values.

Specified by:

enter in interface AggregationMethod

Parameters:

value - to add to aggregate

applyEnterCodegen

public static void applyEnterCodegen(AggregationMethodFactoryNth forge,
                                     int column,
                                     CodegenMethodNode method,
                                     ExprForgeCodegenSymbol symbols,
                                     ExprForge[] forges,
                                     CodegenClassScope classScope)

leave

public void leave(java.lang.Object value)

Description copied from interface: AggregationMethod

Apply the value as leaving aggregation (leaving window).

The value can be null since 'null' values may be counted as unique separate values.

Specified by:

leave in interface AggregationMethod

Parameters:

value - to remove from aggregate

applyLeaveCodegen

public static void applyLeaveCodegen(AggregationMethodFactoryNth forge,
                                     int column,
                                     CodegenMethodNode method,
                                     ExprForgeCodegenSymbol symbols,
                                     ExprForge[] forges,
                                     CodegenClassScope classScope)

clear

public void clear()

Description copied from interface: AggregationMethod

Clear out the collection.

Specified by:

clear in interface AggregationMethod

clearCodegen

public static void clearCodegen(AggregationMethodFactoryNth forge,
                                int column,
                                CodegenMethodNode method)

getValue

public java.lang.Object getValue()

Description copied from interface: AggregationMethod

Returns the current value held.

Specified by:

getValue in interface AggregationMethod

Returns:

current value

getValueCodegen

public static void getValueCodegen(AggregationMethodFactoryNth forge,
                                   int column,
                                   CodegenMethodNode method)

enterValues

protected void enterValues(java.lang.Object[] arr)

getSizeBuf

public int getSizeBuf()

getCircularBuffer

public java.lang.Object[] getCircularBuffer()

setCircularBuffer

public void setCircularBuffer(java.lang.Object[] circularBuffer)

getCurrentBufferElementPointer

public int getCurrentBufferElementPointer()

setCurrentBufferElementPointer

public void setCurrentBufferElementPointer(int currentBufferElementPointer)

getNumDataPoints

public long getNumDataPoints()

setNumDataPoints

public void setNumDataPoints(long numDataPoints)