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

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

public class AggregatorCount
extends AggregatorMethodWDistinctWFilterBase

Field Summary

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

distinct, hasFilter, optionalDistinctSerde, optionalDistinctValueType, optionalFilter

Constructor Summary

Constructors

Constructor and Description
AggregatorCount(EPType optionalDistinctValueType, DataInputOutputSerdeForge optionalDistinctSerde, boolean hasFilter, ExprNode optionalFilter, boolean isEver)

Method Summary

Modifier and Type	Method and Description
protected 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

Methods inherited from class java.lang.Object

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

Constructor Detail

AggregatorCount

public AggregatorCount(EPType optionalDistinctValueType,
                       DataInputOutputSerdeForge optionalDistinctSerde,
                       boolean hasFilter,
                       ExprNode optionalFilter,
                       boolean isEver)

Method Detail

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

applyTableEnterFiltered

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

Specified by:

applyTableEnterFiltered in class AggregatorMethodWDistinctWFilterBase

applyEvalLeaveCodegen

public void applyEvalLeaveCodegen(CodegenMethod method,
                                  ExprForgeCodegenSymbol symbols,
                                  ExprForge[] forges,
                                  CodegenClassScope classScope)

Specified by:

applyEvalLeaveCodegen in interface AggregatorMethod

Overrides:

applyEvalLeaveCodegen in class AggregatorMethodWDistinctWFilterBase

applyEvalLeaveFiltered

public void applyEvalLeaveFiltered(CodegenMethod method,
                                   ExprForgeCodegenSymbol symbols,
                                   ExprForge[] forges,
                                   CodegenClassScope classScope)

Specified by:

applyEvalLeaveFiltered 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