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

Class ExprNodeUtilityAggregation

java.lang.Object

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

public class ExprNodeUtilityAggregation
extends Object

Constructor Summary

Constructors

Constructor	Description
ExprNodeUtilityAggregation()

Method Summary

Modifier and Type	Method	Description
static void	addNonAggregatedProps(ExprNode exprNode, ExprNodePropOrStreamSet set, EventType[] types, ContextPropertyRegistry contextPropertyRegistry)
static ExprNodePropOrStreamSet	getAggregatedProperties(List<ExprAggregateNode> aggregateNodes)
static ExprNodePropOrStreamSet	getGroupByPropertiesValidateHasOne(ExprNode[] groupByNodes)
static ExprNodePropOrStreamSet	getNonAggregatedProps(EventType[] types, List<ExprNode> exprNodes, ContextPropertyRegistry contextPropertyRegistry)
static boolean	hasRemoveStreamForAggregations(ExprNode child, StreamTypeService streamTypeService, boolean unidirectionalJoin)	Returns true if all properties within the expression are witin data window'd streams.

Methods inherited from class java.lang.Object

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

Constructor Details

ExprNodeUtilityAggregation

public ExprNodeUtilityAggregation()

Method Details

hasRemoveStreamForAggregations

public static boolean hasRemoveStreamForAggregations(ExprNode child,
 StreamTypeService streamTypeService,
 boolean unidirectionalJoin)

Returns true if all properties within the expression are witin data window'd streams.

Parameters:

child - expression to interrogate

streamTypeService - streams

unidirectionalJoin - indicator unidirection join

Returns:

indicator

getAggregatedProperties

public static ExprNodePropOrStreamSet getAggregatedProperties(List<ExprAggregateNode> aggregateNodes)

addNonAggregatedProps

public static void addNonAggregatedProps(ExprNode exprNode,
 ExprNodePropOrStreamSet set,
 EventType[] types,
 ContextPropertyRegistry contextPropertyRegistry)

getNonAggregatedProps

public static ExprNodePropOrStreamSet getNonAggregatedProps(EventType[] types,
 List<ExprNode> exprNodes,
 ContextPropertyRegistry contextPropertyRegistry)

getGroupByPropertiesValidateHasOne

public static ExprNodePropOrStreamSet getGroupByPropertiesValidateHasOne(ExprNode[] groupByNodes)
                                                                  throws ExprValidationException

Throws:

ExprValidationException