com.espertech.esper.epl.core

Class ResultSetProcessorRowPerGroupFactory

java.lang.Object

com.espertech.esper.epl.core.ResultSetProcessorRowPerGroupFactory

All Implemented Interfaces:

ResultSetProcessorFactory

public class ResultSetProcessorRowPerGroupFactory
extends 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

Constructors

Constructor and Description

ResultSetProcessorRowPerGroupFactory(SelectExprProcessor selectExprProcessor, ExprNode[] groupKeyNodeExpressions, ExprEvaluator[] groupKeyNodes, ExprEvaluator optionalHavingNode, boolean isSelectRStream, boolean isUnidirectional, OutputLimitSpec outputLimitSpec, boolean isSorting, boolean noDataWindowSingleStream, boolean isHistoricalOnly, boolean iterateUnbounded, ResultSetProcessorHelperFactory resultSetProcessorHelperFactory, boolean enableOutputLimitOpt, int numStreams, OutputConditionPolledFactory optionalOutputFirstConditionFactory)

Method Summary

Modifier and Type	Method and Description
ExprEvaluator	getGroupKeyNode()
ExprNode[]	getGroupKeyNodeExpressions()
ExprEvaluator[]	getGroupKeyNodes()
int	getNumStreams()
ExprEvaluator	getOptionalHavingNode()
OutputConditionPolledFactory	getOptionalOutputFirstConditionFactory()
OutputLimitSpec	getOutputLimitSpec()
EventType	getResultEventType() Returns the event type of processed results.
ResultSetProcessorHelperFactory	getResultSetProcessorHelperFactory()
ResultSetProcessorType	getResultSetProcessorType() Returns the type of result set processor.
boolean	hasAggregation()
ResultSetProcessor	instantiate(OrderByProcessor orderByProcessor, AggregationService aggregationService, AgentInstanceContext agentInstanceContext)
boolean	isEnableOutputLimitOpt()
boolean	isHistoricalOnly()
boolean	isOutputAll()
boolean	isOutputFirst()
boolean	isOutputLast()
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

ResultSetProcessorRowPerGroupFactory

public ResultSetProcessorRowPerGroupFactory(SelectExprProcessor selectExprProcessor,
                                            ExprNode[] groupKeyNodeExpressions,
                                            ExprEvaluator[] groupKeyNodes,
                                            ExprEvaluator optionalHavingNode,
                                            boolean isSelectRStream,
                                            boolean isUnidirectional,
                                            OutputLimitSpec outputLimitSpec,
                                            boolean isSorting,
                                            boolean noDataWindowSingleStream,
                                            boolean isHistoricalOnly,
                                            boolean iterateUnbounded,
                                            ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
                                            boolean enableOutputLimitOpt,
                                            int numStreams,
                                            OutputConditionPolledFactory optionalOutputFirstConditionFactory)

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()

getOptionalHavingNode

public ExprEvaluator getOptionalHavingNode()

isSorting

public boolean isSorting()

isSelectRStream

public boolean isSelectRStream()

isUnidirectional

public boolean isUnidirectional()

getOutputLimitSpec

public OutputLimitSpec getOutputLimitSpec()

getGroupKeyNodeExpressions

public ExprNode[] getGroupKeyNodeExpressions()

isHistoricalOnly

public boolean isHistoricalOnly()

getResultSetProcessorType

public ResultSetProcessorType getResultSetProcessorType()

Description copied from interface: ResultSetProcessorFactory

Returns the type of result set processor.

Specified by:

getResultSetProcessorType in interface ResultSetProcessorFactory

Returns:

result set processor type

isOutputLast

public boolean isOutputLast()

isOutputAll

public boolean isOutputAll()

isEnableOutputLimitOpt

public boolean isEnableOutputLimitOpt()

getNumStreams

public int getNumStreams()

isOutputFirst

public boolean isOutputFirst()

getOptionalOutputFirstConditionFactory

public OutputConditionPolledFactory getOptionalOutputFirstConditionFactory()

getResultSetProcessorHelperFactory

public ResultSetProcessorHelperFactory getResultSetProcessorHelperFactory()