Package com.espertech.esper.common.internal.epl.agg.method.sum

Class AggregatorSumBase

java.lang.Object

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

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

com.espertech.esper.common.internal.epl.agg.method.sum.AggregatorSumBase

All Implemented Interfaces:

AggregatorMethod

Direct Known Subclasses:

AggregatorSumBig, AggregatorSumNonBig

public abstract class AggregatorSumBase
extends AggregatorMethodWDistinctWFilterWValueBase

Field Summary

Fields

Modifier and Type	Field	Description
protected CodegenExpressionMember	cnt
protected CodegenExpressionMember	sum
protected EPTypeClass	sumType

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

distinct, hasFilter, optionalDistinctSerde, optionalDistinctValueType, optionalFilter

Constructor Summary

Constructors

Constructor	Description
AggregatorSumBase(EPTypeClass optionalDistinctValueType, DataInputOutputSerdeForge optionalDistinctSerde, boolean hasFilter, ExprNode optionalFilter, EPTypeClass sumType)

Method Summary

Modifier and Type	Method	Description
protected void	appendFormatWODistinct(FabricTypeCollector collector)
protected abstract void	appendSumFormat(FabricTypeCollector collector)
protected abstract void	applyAggEnterSum(CodegenExpressionRef value, EPType valueType, CodegenMethod method)
protected abstract void	applyAggLeaveSum(CodegenExpressionRef value, EPType valueType, CodegenMethod method)
protected final void	applyEvalEnterNonNull(CodegenExpressionRef value, EPType valueType, CodegenMethod method, ExprForgeCodegenSymbol symbols, ExprForge[] forges, CodegenClassScope classScope)
protected final void	applyEvalLeaveNonNull(CodegenExpressionRef value, EPType valueType, CodegenMethod method, ExprForgeCodegenSymbol symbols, ExprForge[] forges, CodegenClassScope classScope)
protected final void	applyTableEnterNonNull(CodegenExpressionRef value, EPType[] evaluationTypes, CodegenMethod method, CodegenClassScope classScope)
protected abstract void	applyTableEnterSum(CodegenExpressionRef value, EPType[] evaluationTypes, CodegenMethod method, CodegenClassScope classScope)
protected final void	applyTableLeaveNonNull(CodegenExpressionRef value, EPType[] evaluationTypes, CodegenMethod method, CodegenClassScope classScope)
protected abstract void	applyTableLeaveSum(CodegenExpressionRef value, EPType[] evaluationTypes, CodegenMethod method, CodegenClassScope classScope)
protected final void	clearWODistinct(CodegenMethod method, CodegenClassScope classScope)
void	getValueCodegen(CodegenMethod method, CodegenClassScope classScope)
void	initForgeFiltered(int col, CodegenCtor rowCtor, CodegenMemberCol membersColumnized, CodegenClassScope classScope)
protected abstract CodegenExpression	initOfSum()
protected abstract void	readSum(CodegenExpressionRef row, CodegenExpressionRef input, CodegenMethod method, CodegenClassScope classScope)
protected final void	readWODistinct(CodegenExpressionRef row, int col, CodegenExpressionRef input, CodegenExpressionRef unitKey, CodegenMethod method, CodegenClassScope classScope)
protected abstract void	writeSum(CodegenExpressionRef row, CodegenExpressionRef output, CodegenMethod method, CodegenClassScope classScope)
protected final 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.AggregatorMethodWDistinctWFilterWValueBase

applyEvalEnterFiltered, applyEvalLeaveFiltered, applyTableEnterFiltered, applyTableLeaveFiltered

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

cnt

protected CodegenExpressionMember cnt

sum

protected CodegenExpressionMember sum

sumType

protected EPTypeClass sumType

Constructor Details

AggregatorSumBase

public AggregatorSumBase(EPTypeClass optionalDistinctValueType,
 DataInputOutputSerdeForge optionalDistinctSerde,
 boolean hasFilter,
 ExprNode optionalFilter,
 EPTypeClass sumType)

Method Details

initOfSum

protected abstract CodegenExpression initOfSum()

applyAggEnterSum

protected abstract void applyAggEnterSum(CodegenExpressionRef value,
 EPType valueType,
 CodegenMethod method)

applyTableEnterSum

protected abstract void applyTableEnterSum(CodegenExpressionRef value,
 EPType[] evaluationTypes,
 CodegenMethod method,
 CodegenClassScope classScope)

applyAggLeaveSum

protected abstract void applyAggLeaveSum(CodegenExpressionRef value,
 EPType valueType,
 CodegenMethod method)

applyTableLeaveSum

protected abstract void applyTableLeaveSum(CodegenExpressionRef value,
 EPType[] evaluationTypes,
 CodegenMethod method,
 CodegenClassScope classScope)

writeSum

protected abstract void writeSum(CodegenExpressionRef row,
 CodegenExpressionRef output,
 CodegenMethod method,
 CodegenClassScope classScope)

readSum

protected abstract void readSum(CodegenExpressionRef row,
 CodegenExpressionRef input,
 CodegenMethod method,
 CodegenClassScope classScope)

appendSumFormat

protected abstract void appendSumFormat(FabricTypeCollector collector)

initForgeFiltered

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

Specified by:

initForgeFiltered in class AggregatorMethodWDistinctWFilterBase

applyEvalEnterNonNull

protected final void applyEvalEnterNonNull(CodegenExpressionRef value,
 EPType valueType,
 CodegenMethod method,
 ExprForgeCodegenSymbol symbols,
 ExprForge[] forges,
 CodegenClassScope classScope)

Specified by:

applyEvalEnterNonNull in class AggregatorMethodWDistinctWFilterWValueBase

applyTableEnterNonNull

protected final void applyTableEnterNonNull(CodegenExpressionRef value,
 EPType[] evaluationTypes,
 CodegenMethod method,
 CodegenClassScope classScope)

Specified by:

applyTableEnterNonNull in class AggregatorMethodWDistinctWFilterWValueBase

applyEvalLeaveNonNull

protected final void applyEvalLeaveNonNull(CodegenExpressionRef value,
 EPType valueType,
 CodegenMethod method,
 ExprForgeCodegenSymbol symbols,
 ExprForge[] forges,
 CodegenClassScope classScope)

Specified by:

applyEvalLeaveNonNull in class AggregatorMethodWDistinctWFilterWValueBase

applyTableLeaveNonNull

protected final void applyTableLeaveNonNull(CodegenExpressionRef value,
 EPType[] evaluationTypes,
 CodegenMethod method,
 CodegenClassScope classScope)

Specified by:

applyTableLeaveNonNull in class AggregatorMethodWDistinctWFilterWValueBase

clearWODistinct

protected final void clearWODistinct(CodegenMethod method,
 CodegenClassScope classScope)

Specified by:

clearWODistinct in class AggregatorMethodWDistinctWFilterBase

getValueCodegen

public void getValueCodegen(CodegenMethod method,
 CodegenClassScope classScope)

writeWODistinct

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

Specified by:

writeWODistinct in class AggregatorMethodWDistinctWFilterBase

readWODistinct

protected final 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