Class AggregatorCount
java.lang.Object
com.espertech.esper.common.internal.epl.agg.method.core.AggregatorMethodWDistinctWFilterBase
com.espertech.esper.common.internal.epl.agg.method.count.AggregatorCount
- 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
ConstructorDescriptionAggregatorCount
(EPType optionalDistinctValueType, DataInputOutputSerdeForge optionalDistinctSerde, boolean hasFilter, ExprNode optionalFilter, boolean isEver) -
Method Summary
Modifier and TypeMethodDescriptionprotected void
appendFormatWODistinct
(FabricTypeCollector collector) protected void
applyEvalEnterFiltered
(CodegenMethod method, ExprForgeCodegenSymbol symbols, ExprForge[] forges, CodegenClassScope classScope) void
applyEvalLeaveCodegen
(CodegenMethod method, ExprForgeCodegenSymbol symbols, ExprForge[] forges, CodegenClassScope classScope) 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, applyTableEnterCodegen, applyTableLeaveCodegen, clearCodegen, collectFabricType, initForge, readCodegen, toDistinctValueKey, writeCodegen
-
Constructor Details
-
AggregatorCount
public AggregatorCount(EPType optionalDistinctValueType, DataInputOutputSerdeForge optionalDistinctSerde, boolean hasFilter, ExprNode optionalFilter, boolean isEver)
-
-
Method Details
-
initForgeFiltered
public void initForgeFiltered(int col, CodegenCtor rowCtor, CodegenMemberCol membersColumnized, CodegenClassScope classScope) - Specified by:
initForgeFiltered
in classAggregatorMethodWDistinctWFilterBase
-
applyEvalEnterFiltered
protected void applyEvalEnterFiltered(CodegenMethod method, ExprForgeCodegenSymbol symbols, ExprForge[] forges, CodegenClassScope classScope) - Specified by:
applyEvalEnterFiltered
in classAggregatorMethodWDistinctWFilterBase
-
applyTableEnterFiltered
protected void applyTableEnterFiltered(CodegenExpressionRef value, EPType[] evaluationTypes, CodegenMethod method, CodegenClassScope classScope) - Specified by:
applyTableEnterFiltered
in classAggregatorMethodWDistinctWFilterBase
-
applyEvalLeaveCodegen
public void applyEvalLeaveCodegen(CodegenMethod method, ExprForgeCodegenSymbol symbols, ExprForge[] forges, CodegenClassScope classScope) - Specified by:
applyEvalLeaveCodegen
in interfaceAggregatorMethod
- Overrides:
applyEvalLeaveCodegen
in classAggregatorMethodWDistinctWFilterBase
-
applyEvalLeaveFiltered
public void applyEvalLeaveFiltered(CodegenMethod method, ExprForgeCodegenSymbol symbols, ExprForge[] forges, CodegenClassScope classScope) - Specified by:
applyEvalLeaveFiltered
in classAggregatorMethodWDistinctWFilterBase
-
applyTableLeaveFiltered
protected void applyTableLeaveFiltered(CodegenExpressionRef value, EPType[] evaluationTypes, CodegenMethod method, CodegenClassScope classScope) - Specified by:
applyTableLeaveFiltered
in classAggregatorMethodWDistinctWFilterBase
-
clearWODistinct
- Specified by:
clearWODistinct
in classAggregatorMethodWDistinctWFilterBase
-
getValueCodegen
-
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
-