com.espertech.esper.epl.core
Class ResultSetProcessorAggregateAllFactory

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

All Implemented Interfaces:

ResultSetProcessorFactory

public class ResultSetProcessorAggregateAllFactory
extends java.lang.Object
implements ResultSetProcessorFactory

Result set processor prototype for the case: aggregation functions used in the select clause, and no group-by, and not all of the properties in the select clause are under an aggregation function.

Constructor Summary

ResultSetProcessorAggregateAllFactory(SelectExprProcessor selectExprProcessor, ExprEvaluator optionalHavingNode, boolean isSelectRStream, boolean isUnidirectional, boolean isHistoricalOnly, OutputLimitSpec outputLimitSpec, boolean enableOutputLimitOpt, ResultSetProcessorHelperFactory resultSetProcessorHelperFactory)
Ctor.

Method Summary

ExprEvaluator	getOptionalHavingNode()
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	isOutputLast()
boolean	isSelectRStream()
boolean	isUnidirectional()

Methods inherited from class java.lang.Object

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

Constructor Detail

ResultSetProcessorAggregateAllFactory

public ResultSetProcessorAggregateAllFactory(SelectExprProcessor selectExprProcessor,
                                             ExprEvaluator optionalHavingNode,
                                             boolean isSelectRStream,
                                             boolean isUnidirectional,
                                             boolean isHistoricalOnly,
                                             OutputLimitSpec outputLimitSpec,
                                             boolean enableOutputLimitOpt,
                                             ResultSetProcessorHelperFactory resultSetProcessorHelperFactory)

Ctor.

Parameters:

selectExprProcessor - - for processing the select expression and generting the final output rows

optionalHavingNode - - having clause expression node

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

getOptionalHavingNode

public ExprEvaluator getOptionalHavingNode()

isSelectRStream

public boolean isSelectRStream()

isUnidirectional

public boolean isUnidirectional()

isHistoricalOnly

public boolean isHistoricalOnly()

isOutputLast

public boolean isOutputLast()

isOutputAll

public boolean isOutputAll()

isEnableOutputLimitOpt

public boolean isEnableOutputLimitOpt()

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

getResultSetProcessorHelperFactory

public ResultSetProcessorHelperFactory getResultSetProcessorHelperFactory()