com.espertech.esper.epl.agg.aggregator

Class AggregatorRate

java.lang.Object

com.espertech.esper.epl.agg.aggregator.AggregatorRate

All Implemented Interfaces:

AggregationMethod

Direct Known Subclasses:

AggregatorRateFilter

public class AggregatorRate
extends java.lang.Object
implements AggregationMethod

Aggregation computing an event arrival rate for data windowed-events.

Field Summary

Fields

Modifier and Type	Field and Description
protected double	accumulator
protected boolean	isSet
protected long	latest
protected long	oldest
protected long	oneSecondTime

Constructor Summary

Constructors

Constructor and Description
AggregatorRate(long oneSecondTime)

Method Summary

Modifier and Type	Method and Description
static void	applyEnterCodegen(AggregationMethodFactoryRate forge, int column, CodegenMethodNode method, ExprForgeCodegenSymbol symbols, ExprForge[] forges, CodegenClassScope classScope)
static void	applyLeaveCodegen(AggregationMethodFactoryRate forge, int column, CodegenMethodNode method, ExprForgeCodegenSymbol symbols, ExprForge[] forges, CodegenClassScope classScope)
void	clear() Clear out the collection.
static void	clearCodegen(int column, CodegenMethodNode method)
void	enter(java.lang.Object value) Apply the value as entering aggregation (entering window).
protected void	enterValueArr(java.lang.Object[] parameters)
protected void	enterValueSingle(java.lang.Object value)
double	getAccumulator()
long	getLatest()
long	getOldest()
long	getOneSecondTime()
java.lang.Object	getValue() Returns the current value held.
static void	getValueCodegen(AggregationMethodFactoryRate forge, int column, CodegenMethodNode method)
boolean	isSet()
void	leave(java.lang.Object value) Apply the value as leaving aggregation (leaving window).
protected void	leaveValueArr(java.lang.Object[] parameters)
protected void	leaveValueSingle(java.lang.Object value)
static void	rowMemberCodegen(int column, CodegenCtor ctor, CodegenMembersColumnized membersColumnized)
void	setAccumulator(double accumulator)
void	setLatest(long latest)
void	setOldest(long oldest)
void	setSet(boolean set)

Methods inherited from class java.lang.Object

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

Field Detail

oneSecondTime

protected final long oneSecondTime

accumulator

protected double accumulator

latest

protected long latest

oldest

protected long oldest

isSet

protected boolean isSet

Constructor Detail

AggregatorRate

public AggregatorRate(long oneSecondTime)

Method Detail

rowMemberCodegen

public static void rowMemberCodegen(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(AggregationMethodFactoryRate 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(AggregationMethodFactoryRate 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(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(AggregationMethodFactoryRate forge,
                                   int column,
                                   CodegenMethodNode method)

getOneSecondTime

public long getOneSecondTime()

getAccumulator

public double getAccumulator()

setAccumulator

public void setAccumulator(double accumulator)

getLatest

public long getLatest()

setLatest

public void setLatest(long latest)

getOldest

public long getOldest()

setOldest

public void setOldest(long oldest)

isSet

public boolean isSet()

setSet

public void setSet(boolean set)

enterValueSingle

protected void enterValueSingle(java.lang.Object value)

enterValueArr

protected void enterValueArr(java.lang.Object[] parameters)

leaveValueArr

protected void leaveValueArr(java.lang.Object[] parameters)

leaveValueSingle

protected void leaveValueSingle(java.lang.Object value)