com.espertech.esper.epl.core
Class ResultSetProcessorRowPerGroupRollupFactory

java.lang.Object
  com.espertech.esper.epl.core.ResultSetProcessorRowPerGroupRollupFactory

All Implemented Interfaces:

ResultSetProcessorFactory

public class ResultSetProcessorRowPerGroupRollupFactory
extends java.lang.Object
implements ResultSetProcessorFactory

Result set processor prototype for the fully-grouped case: there is a group-by and all non-aggregation event properties in the select clause are listed in the group by, and there are aggregation functions.

Constructor Summary

ResultSetProcessorRowPerGroupRollupFactory(GroupByRollupPerLevelExpression perLevelExpression, ExprNode[] groupKeyNodeExpressions, ExprEvaluator[] groupKeyNodes, boolean isSelectRStream, boolean isUnidirectional, OutputLimitSpec outputLimitSpec, boolean isSorting, boolean noDataWindowSingleStream, AggregationGroupByRollupDesc groupByRollupDesc, boolean isJoin, boolean isHistoricalOnly, boolean iterateUnbounded)
Ctor.

Method Summary

AggregationGroupByRollupDesc	getGroupByRollupDesc()
ExprEvaluator	getGroupKeyNode()
ExprNode[]	getGroupKeyNodeExpressions()
ExprEvaluator[]	getGroupKeyNodes()
OutputLimitSpec	getOutputLimitSpec()
GroupByRollupPerLevelExpression	getPerLevelExpression()
EventType	getResultEventType() Returns the event type of processed results.
boolean	hasAggregation()
ResultSetProcessor	instantiate(OrderByProcessor orderByProcessor, AggregationService aggregationService, AgentInstanceContext agentInstanceContext)
boolean	isHistoricalOnly()
boolean	isJoin()
boolean	isSelectRStream()
boolean	isSorting()
boolean	isUnidirectional()

Methods inherited from class java.lang.Object

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

Constructor Detail

ResultSetProcessorRowPerGroupRollupFactory

public ResultSetProcessorRowPerGroupRollupFactory(GroupByRollupPerLevelExpression perLevelExpression,
                                                  ExprNode[] groupKeyNodeExpressions,
                                                  ExprEvaluator[] groupKeyNodes,
                                                  boolean isSelectRStream,
                                                  boolean isUnidirectional,
                                                  OutputLimitSpec outputLimitSpec,
                                                  boolean isSorting,
                                                  boolean noDataWindowSingleStream,
                                                  AggregationGroupByRollupDesc groupByRollupDesc,
                                                  boolean isJoin,
                                                  boolean isHistoricalOnly,
                                                  boolean iterateUnbounded)

Ctor.

Parameters:

groupKeyNodes - - list of group-by expression nodes needed for building the group-by keys Aggregation functions in the having node must have been pointed to the AggregationService for evaluation.

isSelectRStream - - true if remove stream events should be generated

isUnidirectional - - true if unidirectional join

Method Detail

instantiate

public ResultSetProcessor instantiate(OrderByProcessor orderByProcessor,
                                      AggregationService aggregationService,
                                      AgentInstanceContext agentInstanceContext)

Specified by:

instantiate in interface ResultSetProcessorFactory

getResultEventType

public EventType getResultEventType()

Description copied from interface: ResultSetProcessorFactory

Returns the event type of processed results.

Specified by:

getResultEventType in interface ResultSetProcessorFactory

Returns:

event type of the resulting events posted by the processor.

hasAggregation

public boolean hasAggregation()

Specified by:

hasAggregation in interface ResultSetProcessorFactory

getGroupKeyNodes

public ExprEvaluator[] getGroupKeyNodes()

getGroupKeyNode

public ExprEvaluator getGroupKeyNode()

isSorting

public boolean isSorting()

isSelectRStream

public boolean isSelectRStream()

isUnidirectional

public boolean isUnidirectional()

getOutputLimitSpec

public OutputLimitSpec getOutputLimitSpec()

getGroupKeyNodeExpressions

public ExprNode[] getGroupKeyNodeExpressions()

getGroupByRollupDesc

public AggregationGroupByRollupDesc getGroupByRollupDesc()

getPerLevelExpression

public GroupByRollupPerLevelExpression getPerLevelExpression()

isJoin

public boolean isJoin()

isHistoricalOnly

public boolean isHistoricalOnly()