com.espertech.esper.epl.agg.aggregator

Class AggregatorRateEver

java.lang.Object

com.espertech.esper.epl.agg.aggregator.AggregatorRateEver

All Implemented Interfaces:

AggregationMethod

Direct Known Subclasses:

AggregatorRateEverFilter

public class AggregatorRateEver
extends java.lang.Object
implements AggregationMethod

Aggregation computing an event arrival rate for with and without data window.

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	hasLeave
protected long	interval
protected long	oneSecondTime
protected java.util.ArrayDeque<java.lang.Long>	points
protected TimeProvider	timeProvider

Constructor Summary

Constructors

Constructor and Description
AggregatorRateEver(long interval, long oneSecondTime, TimeProvider timeProvider) Ctor.

Method Summary

Modifier and Type	Method and Description
static void	applyEnterCodegen(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 object) Apply the value as entering aggregation (entering window).
long	getInterval()
long	getOneSecondTime()
java.util.ArrayDeque<java.lang.Long>	getPoints()
TimeProvider	getTimeProvider()
java.lang.Object	getValue() Returns the current value held.
static void	getValueCodegen(AggregationMethodFactoryRate forge, int column, CodegenMethodNode method)
boolean	isHasLeave()
void	leave(java.lang.Object object) Apply the value as leaving aggregation (leaving window).
static boolean	removeFromHead(java.util.ArrayDeque<java.lang.Long> points, long timestamp, long interval) NOTE: Code-generation-invoked method, method name and parameter order matters
static void	rowMemberCodegen(int column, CodegenCtor ctor, CodegenMembersColumnized membersColumnized)
void	setHasLeave(boolean hasLeave)

Methods inherited from class java.lang.Object

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

Field Detail

interval

protected final long interval

oneSecondTime

protected final long oneSecondTime

points

protected final java.util.ArrayDeque<java.lang.Long> points

hasLeave

protected boolean hasLeave

timeProvider

protected final TimeProvider timeProvider

Constructor Detail

AggregatorRateEver

public AggregatorRateEver(long interval,
                          long oneSecondTime,
                          TimeProvider timeProvider)

Ctor.

Parameters:

interval - rate interval

timeProvider - time

oneSecondTime - number of ticks for one second

Method Detail

rowMemberCodegen

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

enter

public void enter(java.lang.Object object)

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:

object - 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 object)

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:

object - to remove from aggregate

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)

getInterval

public long getInterval()

getOneSecondTime

public long getOneSecondTime()

getPoints

public java.util.ArrayDeque<java.lang.Long> getPoints()

isHasLeave

public boolean isHasLeave()

setHasLeave

public void setHasLeave(boolean hasLeave)

getTimeProvider

public TimeProvider getTimeProvider()

removeFromHead

public static boolean removeFromHead(java.util.ArrayDeque<java.lang.Long> points,
                                     long timestamp,
                                     long interval)

NOTE: Code-generation-invoked method, method name and parameter order matters

Parameters:

points - points

timestamp - timestamp

interval - interval

Returns:

hasLeave