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

Class AggregatorRate

java.lang.Object

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

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

All Implemented Interfaces:

AggregatorMethod

public class AggregatorRate
extends AggregatorMethodWDistinctWFilterBase

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

Field Summary

Fields

Modifier and Type	Field and Description
protected CodegenExpressionRef	accumulator
protected AggregationFactoryMethodRate	factory
protected CodegenExpressionRef	isSet
protected CodegenExpressionRef	latest
protected CodegenExpressionRef	oldest

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

distinct, hasFilter, optionalDistinctValueType, optionalFilter

Constructor Summary

Constructors

Constructor and Description
AggregatorRate(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	applyEvalEnterFiltered(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)
protected void	readWODistinct(CodegenExpressionRef row, int col, CodegenExpressionRef input, CodegenExpressionRef unitKey, CodegenMethod method, CodegenClassScope classScope)
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, applyEvalLeaveCodegen, 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 AggregationFactoryMethodRate factory

accumulator

protected CodegenExpressionRef accumulator

latest

protected CodegenExpressionRef latest

oldest

protected CodegenExpressionRef oldest

isSet

protected CodegenExpressionRef isSet

Constructor Detail

AggregatorRate

public AggregatorRate(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

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