Package com.espertech.esper.common.internal.epl.expression.agg.accessagg

Class ExprAggMultiFunctionCountMinSketchNode

java.lang.Object

com.espertech.esper.common.internal.epl.expression.core.ExprNodeBase

com.espertech.esper.common.internal.epl.expression.agg.base.ExprAggregateNodeBase

com.espertech.esper.common.internal.epl.expression.agg.accessagg.ExprAggMultiFunctionCountMinSketchNode

All Implemented Interfaces:

ExprAggMultiFunctionNode, ExprAggregateNode, ExprEnumerationEval, ExprEnumerationForge, ExprEvaluator, ExprForge, ExprForgeInstrumentable, ExprNode, ExprNodeRenderable, ExprValidator

public class ExprAggMultiFunctionCountMinSketchNode
extends ExprAggregateNodeBase
implements ExprAggMultiFunctionNode, ExprEnumerationEval

Represents the Count-min sketch aggregate function.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	MSG_NAME

Fields inherited from class com.espertech.esper.common.internal.epl.expression.agg.base.ExprAggregateNodeBase

aggregationResultFutureMemberName, column, isDistinct, optionalAggregateLocalGroupByDesc, optionalFilter, positionalParams

Fields inherited from interface com.espertech.esper.common.internal.epl.expression.core.ExprEvaluator

EPTYPE, EPTYPEARRAY

Constructor Summary

Constructors

Constructor	Description
ExprAggMultiFunctionCountMinSketchNode(boolean distinct, CountMinSketchAggType aggType)

Method Summary

Modifier and Type	Method	Description
final boolean	equalsNodeAggregateMethodOnly(ExprAggregateNode node)	Return true if a expression aggregate node semantically equals the current node, or false if not.
EventBean	evaluateGetEventBean(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
CodegenExpression	evaluateGetEventBeanCodegen(CodegenMethodScope codegenMethodScope, ExprForgeCodegenSymbol exprSymbol, CodegenClassScope codegenClassScope)
Collection<EventBean>	evaluateGetROCollectionEvents(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
CodegenExpression	evaluateGetROCollectionEventsCodegen(CodegenMethodScope codegenMethodScope, ExprForgeCodegenSymbol exprSymbol, CodegenClassScope codegenClassScope)
Collection	evaluateGetROCollectionScalar(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
CodegenExpression	evaluateGetROCollectionScalarCodegen(CodegenMethodScope codegenMethodScope, ExprForgeCodegenSymbol exprSymbol, CodegenClassScope codegenClassScope)
AggregationForgeFactory	getAggregationForgeFactory()
String	getAggregationFunctionName()	Returns the aggregation function name for representation in a generate expression string.
CountMinSketchAggType	getAggType()
EPTypeClass	getComponentTypeCollection()
ExprValidationException	getDeclaredWrongParameterExpr()
EventType	getEventTypeCollection(StatementRawInfo statementRawInfo, StatementCompileTimeServices compileTimeServices)
EventType	getEventTypeSingle(StatementRawInfo statementRawInfo, StatementCompileTimeServices compileTimeServices)
ExprEnumerationEval	getExprEvaluatorEnumeration()
protected boolean	isExprTextWildcardWhenNoParams()
protected boolean	isFilterExpressionAsLastParameter()
AggregationForgeFactory	validateAggregationChild(ExprValidationContext validationContext)	Gives the aggregation node a chance to validate the sub-expression types.

Methods inherited from class com.espertech.esper.common.internal.epl.expression.agg.base.ExprAggregateNodeBase

equalsNode, evaluate, evaluateCodegen, evaluateCodegenUninstrumented, getAggFuture, getColumn, getEvaluationType, getExprEvaluator, getFactory, getForge, getForgeConstantType, getForgeRenderable, getOptionalFilter, getOptionalLocalGroupBy, getPositionalParams, getPrecedence, isConstantResult, isDistinct, makeExceptionExpectedParamNum, setColumn, toPrecedenceFreeEPL, validate, validateFilter, validateNumericChildAllowFilter, validatePositionals

Methods inherited from class com.espertech.esper.common.internal.epl.expression.core.ExprNodeBase

accept, accept, acceptChildnodes, addChildNode, addChildNodes, addChildNodeToFront, checkValidated, checkValidatedException, getChildNodes, replaceUnlistedChildNode, setChildNode, setChildNodes, toEPL

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.espertech.esper.common.internal.epl.expression.agg.accessagg.ExprAggMultiFunctionNode

getAggFuture, getColumn

Methods inherited from interface com.espertech.esper.common.internal.epl.expression.core.ExprEnumerationForge

getForgeRenderable

Methods inherited from interface com.espertech.esper.common.internal.epl.expression.core.ExprNode

accept, accept, acceptChildnodes, addChildNode, addChildNodes, equalsNode, getChildNodes, getForge, getPrecedence, replaceUnlistedChildNode, setChildNode, setChildNodes

Methods inherited from interface com.espertech.esper.common.internal.epl.expression.core.ExprNodeRenderable

toEPL

Methods inherited from interface com.espertech.esper.common.internal.epl.expression.core.ExprValidator

validate

Field Details

MSG_NAME

public static final String MSG_NAME

See Also:

• Constant Field Values

Constructor Details

ExprAggMultiFunctionCountMinSketchNode

public ExprAggMultiFunctionCountMinSketchNode(boolean distinct,
 CountMinSketchAggType aggType)

Method Details

validateAggregationChild

public AggregationForgeFactory validateAggregationChild(ExprValidationContext validationContext)
                                                 throws ExprValidationException

Description copied from class: ExprAggregateNodeBase

Gives the aggregation node a chance to validate the sub-expression types.

Specified by:

validateAggregationChild in class ExprAggregateNodeBase

Parameters:

validationContext - validation information

Returns:

aggregation function factory to use

Throws:

ExprValidationException - when expression validation failed

getExprEvaluatorEnumeration

public ExprEnumerationEval getExprEvaluatorEnumeration()

Specified by:

getExprEvaluatorEnumeration in interface ExprEnumerationForge

getAggregationFunctionName

public String getAggregationFunctionName()

Description copied from class: ExprAggregateNodeBase

Returns the aggregation function name for representation in a generate expression string.

Specified by:

getAggregationFunctionName in class ExprAggregateNodeBase

Returns:

aggregation function name

equalsNodeAggregateMethodOnly

public final boolean equalsNodeAggregateMethodOnly(ExprAggregateNode node)

Description copied from class: ExprAggregateNodeBase

Return true if a expression aggregate node semantically equals the current node, or false if not.

For use by the equalsNode implementation which compares the distinct flag.

Specified by:

equalsNodeAggregateMethodOnly in class ExprAggregateNodeBase

Parameters:

node - to compare to

Returns:

true if semantically equal, or false if not equals

getAggType

public CountMinSketchAggType getAggType()

getEventTypeCollection

public EventType getEventTypeCollection(StatementRawInfo statementRawInfo,
 StatementCompileTimeServices compileTimeServices)
                                 throws ExprValidationException

Specified by:

getEventTypeCollection in interface ExprEnumerationForge

Throws:

ExprValidationException

evaluateGetROCollectionEvents

public Collection<EventBean> evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
 boolean isNewData,
 ExprEvaluatorContext context)

Specified by:

evaluateGetROCollectionEvents in interface ExprEnumerationEval

getComponentTypeCollection

public EPTypeClass getComponentTypeCollection()
                                       throws ExprValidationException

Specified by:

getComponentTypeCollection in interface ExprEnumerationForge

Throws:

ExprValidationException

evaluateGetROCollectionScalar

public Collection evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
 boolean isNewData,
 ExprEvaluatorContext context)

Specified by:

evaluateGetROCollectionScalar in interface ExprEnumerationEval

evaluateGetROCollectionScalarCodegen

public CodegenExpression evaluateGetROCollectionScalarCodegen(CodegenMethodScope codegenMethodScope,
 ExprForgeCodegenSymbol exprSymbol,
 CodegenClassScope codegenClassScope)

Specified by:

evaluateGetROCollectionScalarCodegen in interface ExprEnumerationForge

evaluateGetROCollectionEventsCodegen

public CodegenExpression evaluateGetROCollectionEventsCodegen(CodegenMethodScope codegenMethodScope,
 ExprForgeCodegenSymbol exprSymbol,
 CodegenClassScope codegenClassScope)

Specified by:

evaluateGetROCollectionEventsCodegen in interface ExprEnumerationForge

getEventTypeSingle

public EventType getEventTypeSingle(StatementRawInfo statementRawInfo,
 StatementCompileTimeServices compileTimeServices)
                             throws ExprValidationException

Specified by:

getEventTypeSingle in interface ExprEnumerationForge

Throws:

ExprValidationException

evaluateGetEventBean

public EventBean evaluateGetEventBean(EventBean[] eventsPerStream,
 boolean isNewData,
 ExprEvaluatorContext context)

Specified by:

evaluateGetEventBean in interface ExprEnumerationEval

evaluateGetEventBeanCodegen

public CodegenExpression evaluateGetEventBeanCodegen(CodegenMethodScope codegenMethodScope,
 ExprForgeCodegenSymbol exprSymbol,
 CodegenClassScope codegenClassScope)

Specified by:

evaluateGetEventBeanCodegen in interface ExprEnumerationForge

isExprTextWildcardWhenNoParams

protected boolean isExprTextWildcardWhenNoParams()

Overrides:

isExprTextWildcardWhenNoParams in class ExprAggregateNodeBase

getDeclaredWrongParameterExpr

public ExprValidationException getDeclaredWrongParameterExpr()
                                                      throws ExprValidationException

Throws:

ExprValidationException

isFilterExpressionAsLastParameter

protected boolean isFilterExpressionAsLastParameter()

Specified by:

isFilterExpressionAsLastParameter in class ExprAggregateNodeBase

getAggregationForgeFactory

public AggregationForgeFactory getAggregationForgeFactory()

Specified by:

getAggregationForgeFactory in interface ExprAggMultiFunctionNode