Package 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	Description
protected CodegenExpressionMember	accumulator
protected AggregationForgeFactoryRate	factory
protected CodegenExpressionMember	isSet
protected CodegenExpressionMember	latest
protected CodegenExpressionMember	oldest

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

distinct, hasFilter, optionalDistinctSerde, optionalDistinctValueType, optionalFilter

Constructor Summary

Constructors

Constructor	Description
AggregatorRate(AggregationForgeFactoryRate factory, EPTypeClass optionalDistinctValueType, DataInputOutputSerdeForge optionalDistinctSerde, boolean hasFilter, ExprNode optionalFilter)

Method Summary

Modifier and Type	Method	Description
protected void	appendFormatWODistinct(FabricTypeCollector collector)
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, EPType[] evaluationTypes, CodegenMethod method, CodegenClassScope classScope)
protected void	applyTableLeaveFiltered(CodegenExpressionRef value, EPType[] evaluationTypes, CodegenMethod method, CodegenClassScope classScope)
protected void	clearWODistinct(CodegenMethod method, CodegenClassScope classScope)
void	getValueCodegen(CodegenMethod method, CodegenClassScope classScope)
void	initForgeFiltered(int col, CodegenCtor rowCtor, CodegenMemberCol membersColumnized, 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, collectFabricType, initForge, readCodegen, toDistinctValueKey, writeCodegen

Methods inherited from class java.lang.Object

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

Field Details

factory

protected AggregationForgeFactoryRate factory

accumulator

protected CodegenExpressionMember accumulator

latest

protected CodegenExpressionMember latest

oldest

protected CodegenExpressionMember oldest

isSet

protected CodegenExpressionMember isSet

Constructor Details

AggregatorRate

public AggregatorRate(AggregationForgeFactoryRate factory,
 EPTypeClass optionalDistinctValueType,
 DataInputOutputSerdeForge optionalDistinctSerde,
 boolean hasFilter,
 ExprNode optionalFilter)

Method Details

initForgeFiltered

public void initForgeFiltered(int col,
 CodegenCtor rowCtor,
 CodegenMemberCol membersColumnized,
 CodegenClassScope classScope)

Specified by:

initForgeFiltered in class AggregatorMethodWDistinctWFilterBase

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,
 EPType[] evaluationTypes,
 CodegenMethod method,
 CodegenClassScope classScope)

Specified by:

applyTableEnterFiltered in class AggregatorMethodWDistinctWFilterBase

applyTableLeaveFiltered

protected void applyTableLeaveFiltered(CodegenExpressionRef value,
 EPType[] 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

appendFormatWODistinct

protected void appendFormatWODistinct(FabricTypeCollector collector)

Specified by:

appendFormatWODistinct in class AggregatorMethodWDistinctWFilterBase