Class AggregatorPlugInManaged
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.plugin.AggregatorPlugInManaged
- All Implemented Interfaces:
AggregatorMethod
-
Field Summary
Fields inherited from class com.espertech.esper.common.internal.epl.agg.method.core.AggregatorMethodWDistinctWFilterBase
distinct, hasFilter, optionalDistinctSerde, optionalDistinctValueType, optionalFilter
-
Constructor Summary
ConstructorDescriptionAggregatorPlugInManaged
(EPType optionalDistinctValueType, DataInputOutputSerdeForge optionalDistinctSerde, boolean hasFilter, ExprNode optionalFilter, AggregationFunctionModeManaged mode) -
Method Summary
Modifier and TypeMethodDescriptionprotected void
appendFormatWODistinct
(FabricTypeCollector collector) protected void
applyEvalEnterNonNull
(CodegenExpressionRef value, EPType valueType, CodegenMethod method, ExprForgeCodegenSymbol symbols, ExprForge[] forges, CodegenClassScope classScope) protected void
applyEvalLeaveNonNull
(CodegenExpressionRef value, EPType valueType, CodegenMethod method, ExprForgeCodegenSymbol symbols, ExprForge[] forges, CodegenClassScope classScope) protected void
applyTableEnterNonNull
(CodegenExpressionRef value, EPType[] evaluationTypes, CodegenMethod method, CodegenClassScope classScope) protected void
applyTableLeaveNonNull
(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.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
-
Field Details
-
plugin
-
-
Constructor Details
-
AggregatorPlugInManaged
public AggregatorPlugInManaged(EPType optionalDistinctValueType, DataInputOutputSerdeForge optionalDistinctSerde, boolean hasFilter, ExprNode optionalFilter, AggregationFunctionModeManaged mode)
-
-
Method Details
-
initForgeFiltered
public void initForgeFiltered(int col, CodegenCtor rowCtor, CodegenMemberCol membersColumnized, CodegenClassScope classScope) - Specified by:
initForgeFiltered
in classAggregatorMethodWDistinctWFilterBase
-
applyEvalEnterNonNull
protected void applyEvalEnterNonNull(CodegenExpressionRef value, EPType valueType, CodegenMethod method, ExprForgeCodegenSymbol symbols, ExprForge[] forges, CodegenClassScope classScope) - Specified by:
applyEvalEnterNonNull
in classAggregatorMethodWDistinctWFilterWValueBase
-
applyEvalLeaveNonNull
protected void applyEvalLeaveNonNull(CodegenExpressionRef value, EPType valueType, CodegenMethod method, ExprForgeCodegenSymbol symbols, ExprForge[] forges, CodegenClassScope classScope) - Specified by:
applyEvalLeaveNonNull
in classAggregatorMethodWDistinctWFilterWValueBase
-
applyTableEnterNonNull
protected void applyTableEnterNonNull(CodegenExpressionRef value, EPType[] evaluationTypes, CodegenMethod method, CodegenClassScope classScope) - Specified by:
applyTableEnterNonNull
in classAggregatorMethodWDistinctWFilterWValueBase
-
applyTableLeaveNonNull
protected void applyTableLeaveNonNull(CodegenExpressionRef value, EPType[] evaluationTypes, CodegenMethod method, CodegenClassScope classScope) - Specified by:
applyTableLeaveNonNull
in classAggregatorMethodWDistinctWFilterWValueBase
-
clearWODistinct
- Specified by:
clearWODistinct
in classAggregatorMethodWDistinctWFilterBase
-
writeWODistinct
protected void writeWODistinct(CodegenExpressionRef row, int col, CodegenExpressionRef output, CodegenExpressionRef unitKey, CodegenExpressionRef writer, CodegenMethod method, CodegenClassScope classScope) - Specified by:
writeWODistinct
in classAggregatorMethodWDistinctWFilterBase
-
readWODistinct
protected void readWODistinct(CodegenExpressionRef row, int col, CodegenExpressionRef input, CodegenExpressionRef unitKey, CodegenMethod method, CodegenClassScope classScope) - Specified by:
readWODistinct
in classAggregatorMethodWDistinctWFilterBase
-
appendFormatWODistinct
- Specified by:
appendFormatWODistinct
in classAggregatorMethodWDistinctWFilterBase
-
getValueCodegen
-