com.espertech.esper.common.internal.epl.agg.method.rate

Class AggregatorRateEver

java.lang.Object

com.espertech.esper.common.internal.epl.agg.method.core.AggregatorMethodWDistinctWFilterBase

com.espertech.esper.common.internal.epl.agg.method.rate.AggregatorRateEver

All Implemented Interfaces:

AggregatorMethod

public class AggregatorRateEver
extends AggregatorMethodWDistinctWFilterBase

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

Field Summary

Fields

Modifier and Type	Field and Description
protected AggregationFactoryMethodRate	factory
protected CodegenExpressionRef	hasLeave
protected CodegenExpressionRef	points

Fields inherited from class com.espertech.esper.common.internal.epl.agg.method.core.AggregatorMethodWDistinctWFilterBase

distinct, hasFilter, optionalDistinctValueType, optionalFilter

Constructor Summary

Constructors

Constructor and Description
AggregatorRateEver(AggregationFactoryMethodRate factory, int col, CodegenCtor rowCtor, CodegenMemberCol membersColumnized, CodegenClassScope classScope, Class optionalDistinctValueType, boolean hasFilter, ExprNode optionalFilter)

Method Summary

Modifier and Type	Method and Description
protected void	apply(CodegenMethod method, CodegenClassScope classScope)
protected void	applyEvalEnterFiltered(CodegenMethod method, ExprForgeCodegenSymbol symbols, ExprForge[] forges, CodegenClassScope classScope)
void	applyEvalLeaveCodegen(CodegenMethod method, ExprForgeCodegenSymbol symbols, ExprForge[] forges, CodegenClassScope classScope)
protected void	applyEvalLeaveFiltered(CodegenMethod method, ExprForgeCodegenSymbol symbols, ExprForge[] forges, CodegenClassScope classScope)
protected void	applyTableEnterFiltered(CodegenExpressionRef value, Class[] evaluationTypes, CodegenMethod method, CodegenClassScope classScope)
protected void	applyTableLeaveFiltered(CodegenExpressionRef value, Class[] evaluationTypes, CodegenMethod method, CodegenClassScope classScope)
protected void	clearWODistinct(CodegenMethod method, CodegenClassScope classScope)
void	getValueCodegen(CodegenMethod method, CodegenClassScope classScope)
static Deque<Long>	readPoints(DataInput input) NOTE: Code-generation-invoked method, method name and parameter order matters
protected void	readWODistinct(CodegenExpressionRef row, int col, CodegenExpressionRef input, CodegenExpressionRef unitKey, CodegenMethod method, CodegenClassScope classScope)
static boolean	removeFromHead(Deque<Long> points, long timestamp, long interval) NOTE: Code-generation-invoked method, method name and parameter order matters
static void	writePoints(DataOutput output, Deque<Long> points) NOTE: Code-generation-invoked method, method name and parameter order matters
protected void	writeWODistinct(CodegenExpressionRef row, int col, CodegenExpressionRef output, CodegenExpressionRef unitKey, CodegenExpressionRef writer, CodegenMethod method, CodegenClassScope classScope)

Methods inherited from class com.espertech.esper.common.internal.epl.agg.method.core.AggregatorMethodWDistinctWFilterBase

applyEvalEnterCodegen, applyTableEnterCodegen, applyTableLeaveCodegen, clearCodegen, readCodegen, writeCodegen

Methods inherited from class java.lang.Object

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

Field Detail

factory

protected final AggregationFactoryMethodRate factory

points

protected final CodegenExpressionRef points

hasLeave

protected final CodegenExpressionRef hasLeave

Constructor Detail

AggregatorRateEver

public AggregatorRateEver(AggregationFactoryMethodRate factory,
                          int col,
                          CodegenCtor rowCtor,
                          CodegenMemberCol membersColumnized,
                          CodegenClassScope classScope,
                          Class optionalDistinctValueType,
                          boolean hasFilter,
                          ExprNode optionalFilter)

Method Detail

applyEvalEnterFiltered

protected void applyEvalEnterFiltered(CodegenMethod method,
                                      ExprForgeCodegenSymbol symbols,
                                      ExprForge[] forges,
                                      CodegenClassScope classScope)

Specified by:

applyEvalEnterFiltered in class AggregatorMethodWDistinctWFilterBase

applyEvalLeaveCodegen

public void applyEvalLeaveCodegen(CodegenMethod method,
                                  ExprForgeCodegenSymbol symbols,
                                  ExprForge[] forges,
                                  CodegenClassScope classScope)

Specified by:

applyEvalLeaveCodegen in interface AggregatorMethod

Overrides:

applyEvalLeaveCodegen in class AggregatorMethodWDistinctWFilterBase

applyEvalLeaveFiltered

protected void applyEvalLeaveFiltered(CodegenMethod method,
                                      ExprForgeCodegenSymbol symbols,
                                      ExprForge[] forges,
                                      CodegenClassScope classScope)

Specified by:

applyEvalLeaveFiltered in class AggregatorMethodWDistinctWFilterBase

applyTableEnterFiltered

protected void applyTableEnterFiltered(CodegenExpressionRef value,
                                       Class[] evaluationTypes,
                                       CodegenMethod method,
                                       CodegenClassScope classScope)

Specified by:

applyTableEnterFiltered in class AggregatorMethodWDistinctWFilterBase

applyTableLeaveFiltered

protected void applyTableLeaveFiltered(CodegenExpressionRef value,
                                       Class[] evaluationTypes,
                                       CodegenMethod method,
                                       CodegenClassScope classScope)

Specified by:

applyTableLeaveFiltered in class AggregatorMethodWDistinctWFilterBase

clearWODistinct

protected void clearWODistinct(CodegenMethod method,
                               CodegenClassScope classScope)

Specified by:

clearWODistinct in class AggregatorMethodWDistinctWFilterBase

getValueCodegen

public void getValueCodegen(CodegenMethod method,
                            CodegenClassScope classScope)

writeWODistinct

protected void writeWODistinct(CodegenExpressionRef row,
                               int col,
                               CodegenExpressionRef output,
                               CodegenExpressionRef unitKey,
                               CodegenExpressionRef writer,
                               CodegenMethod method,
                               CodegenClassScope classScope)

Specified by:

writeWODistinct in class AggregatorMethodWDistinctWFilterBase

readWODistinct

protected void readWODistinct(CodegenExpressionRef row,
                              int col,
                              CodegenExpressionRef input,
                              CodegenExpressionRef unitKey,
                              CodegenMethod method,
                              CodegenClassScope classScope)

Specified by:

readWODistinct in class AggregatorMethodWDistinctWFilterBase

writePoints

public static void writePoints(DataOutput output,
                               Deque<Long> points)
                        throws IOException

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

Parameters:

output - out

points - points

Throws:

IOException - io error

apply

protected void apply(CodegenMethod method,
                     CodegenClassScope classScope)

readPoints

public static Deque<Long> readPoints(DataInput input)
                              throws IOException

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

Parameters:

input - input

Returns:

points

Throws:

IOException - io error

removeFromHead

public static boolean removeFromHead(Deque<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