com.espertech.esper.epl.expression.accessagg

Class ExprAggMultiFunctionLinearAccessNode

java.lang.Object

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

com.espertech.esper.epl.expression.baseagg.ExprAggregateNodeBase

com.espertech.esper.epl.expression.accessagg.ExprAggMultiFunctionLinearAccessNode

All Implemented Interfaces:

ExprAggregateAccessMultiValueNode, ExprAggregateNode, ExprEvaluator, ExprEvaluatorEnumeration, ExprNode, ExprValidator, MetaDefItem, Serializable

public class ExprAggMultiFunctionLinearAccessNode
extends ExprAggregateNodeBase
implements ExprEvaluatorEnumeration, ExprAggregateAccessMultiValueNode

See Also:

Serialized Form

Field Summary

Fields inherited from class com.espertech.esper.epl.expression.baseagg.ExprAggregateNodeBase

aggregationResultFuture, column, isDistinct, optionalAggregateLocalGroupByDesc, optionalFilter, positionalParams

Constructor Summary

Constructors

Constructor and Description
ExprAggMultiFunctionLinearAccessNode(AggregationStateType stateType)

Method Summary

Modifier and Type	Method and Description
protected 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)
Collection<EventBean>	evaluateGetROCollectionEvents(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
Collection	evaluateGetROCollectionScalar(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
String	getAggregationFunctionName() Returns the aggregation function name for representation in a generate expression string.
Class	getComponentTypeCollection()
EventType	getEventTypeCollection(EventAdapterService eventAdapterService, int statementId)
EventType	getEventTypeSingle(EventAdapterService eventAdapterService, int statementId)
protected static boolean	getIstreamOnly(StreamTypeService streamTypeService, int streamNum)
AggregationStateType	getStateType()
protected boolean	isFilterExpressionAsLastParameter()
void	toPrecedenceFreeEPL(StringWriter writer)
AggregationMethodFactory	validateAggregationChild(ExprValidationContext validationContext) Gives the aggregation node a chance to validate the sub-expression types.
AggregationMethodFactory	validateAggregationParamsWBinding(ExprValidationContext validationContext, TableMetadataColumnAggregation tableAccessColumn)

Methods inherited from class com.espertech.esper.epl.expression.baseagg.ExprAggregateNodeBase

equalsNode, evaluate, getExprEvaluator, getFactory, getOptionalFilter, getOptionalLocalGroupBy, getPositionalParams, getPrecedence, getType, isConstantResult, isDistinct, isExprTextWildcardWhenNoParams, makeExceptionExpectedParamNum, setAggregationResultFuture, validate, validateFilter, validateNumericChildAllowFilter, validatePositionals

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

accept, accept, acceptChildnodes, addChildNode, addChildNodes, addChildNodeToFront, 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.epl.expression.accessagg.ExprAggregateAccessMultiValueNode

validatePositionals

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

accept, accept, acceptChildnodes, addChildNode, addChildNodes, getChildNodes, replaceUnlistedChildNode, setChildNode, setChildNodes, toEPL

Constructor Detail

ExprAggMultiFunctionLinearAccessNode

public ExprAggMultiFunctionLinearAccessNode(AggregationStateType stateType)

Method Detail

validateAggregationChild

public AggregationMethodFactory 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

validateAggregationParamsWBinding

public AggregationMethodFactory validateAggregationParamsWBinding(ExprValidationContext validationContext,
                                                                  TableMetadataColumnAggregation tableAccessColumn)
                                                           throws ExprValidationException

Specified by:

validateAggregationParamsWBinding in interface ExprAggregateAccessMultiValueNode

Throws:

ExprValidationException

getIstreamOnly

protected static boolean getIstreamOnly(StreamTypeService streamTypeService,
                                        int streamNum)

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

toPrecedenceFreeEPL

public void toPrecedenceFreeEPL(StringWriter writer)

Overrides:

toPrecedenceFreeEPL in class ExprAggregateNodeBase

getStateType

public AggregationStateType getStateType()

evaluateGetROCollectionEvents

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

Specified by:

evaluateGetROCollectionEvents in interface ExprEvaluatorEnumeration

evaluateGetROCollectionScalar

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

Specified by:

evaluateGetROCollectionScalar in interface ExprEvaluatorEnumeration

getEventTypeCollection

public EventType getEventTypeCollection(EventAdapterService eventAdapterService,
                                        int statementId)

Specified by:

getEventTypeCollection in interface ExprEvaluatorEnumeration

getComponentTypeCollection

public Class getComponentTypeCollection()
                                 throws ExprValidationException

Specified by:

getComponentTypeCollection in interface ExprEvaluatorEnumeration

Throws:

ExprValidationException

getEventTypeSingle

public EventType getEventTypeSingle(EventAdapterService eventAdapterService,
                                    int statementId)
                             throws ExprValidationException

Specified by:

getEventTypeSingle in interface ExprEvaluatorEnumeration

Throws:

ExprValidationException

evaluateGetEventBean

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

Specified by:

evaluateGetEventBean in interface ExprEvaluatorEnumeration

equalsNodeAggregateMethodOnly

protected 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

isFilterExpressionAsLastParameter

protected boolean isFilterExpressionAsLastParameter()

Specified by:

isFilterExpressionAsLastParameter in class ExprAggregateNodeBase