com.espertech.esper.common.internal.epl.resultset.rowpergrouprollup

Class ResultSetProcessorRowPerGroupRollupForge

java.lang.Object

com.espertech.esper.common.internal.epl.resultset.rowpergrouprollup.ResultSetProcessorRowPerGroupRollupForge

All Implemented Interfaces:

ResultSetProcessorFactoryForge

public class ResultSetProcessorRowPerGroupRollupForge
extends Object
implements ResultSetProcessorFactoryForge

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

ResultSetProcessorRowPerGroupRollupForge(EventType resultEventType, GroupByRollupPerLevelForge perLevelForges, ExprNode[] groupKeyNodeExpressions, boolean isSelectRStream, boolean isUnidirectional, OutputLimitSpec outputLimitSpec, boolean isSorting, boolean noDataWindowSingleStream, AggregationGroupByRollupDesc groupByRollupDesc, boolean isJoin, boolean isHistoricalOnly, boolean iterateUnbounded, ResultSetProcessorOutputConditionType outputConditionType, OutputConditionPolledFactoryForge optionalOutputFirstConditionFactory, EventType[] eventTypes)

Method Summary

Modifier and Type	Method and Description
void	acceptHelperVisitorCodegen(CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
void	applyJoinResultCodegen(CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
void	applyViewResultCodegen(CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
void	clearMethodCodegen(CodegenClassScope classScope, CodegenMethod method)
void	continueOutputLimitedLastAllNonBufferedJoinCodegen(CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
void	continueOutputLimitedLastAllNonBufferedViewCodegen(CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
EventType[]	getEventTypes()
AggregationGroupByRollupDesc	getGroupByRollupDesc()
ExprNode[]	getGroupKeyNodeExpressions()
Class[]	getGroupKeyTypes()
String	getInstrumentedQName()
Class	getInterfaceClass()
void	getIteratorJoinCodegen(CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
void	getIteratorViewCodegen(CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
int	getNumStreams()
OutputConditionPolledFactoryForge	getOptionalOutputFirstConditionFactory()
ResultSetProcessorOutputConditionType	getOutputConditionType()
OutputLimitSpec	getOutputLimitSpec()
GroupByRollupPerLevelForge	getPerLevelForges()
EventType	getResultEventType()
void	instanceCodegen(CodegenInstanceAux instance, CodegenClassScope classScope, CodegenCtor factoryCtor, List<CodegenTypedParam> factoryMembers)
boolean	isHistoricalOnly()
boolean	isJoin()
boolean	isSelectRStream()
boolean	isSorting()
boolean	isUnidirectional()
void	processJoinResultCodegen(CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
void	processOutputLimitedJoinCodegen(CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
void	processOutputLimitedLastAllNonBufferedJoinCodegen(CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
void	processOutputLimitedLastAllNonBufferedViewCodegen(CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
void	processOutputLimitedViewCodegen(CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
void	processViewResultCodegen(CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
void	stopMethodCodegen(CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)

Methods inherited from class java.lang.Object

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

Constructor Detail

ResultSetProcessorRowPerGroupRollupForge

public ResultSetProcessorRowPerGroupRollupForge(EventType resultEventType,
                                                GroupByRollupPerLevelForge perLevelForges,
                                                ExprNode[] groupKeyNodeExpressions,
                                                boolean isSelectRStream,
                                                boolean isUnidirectional,
                                                OutputLimitSpec outputLimitSpec,
                                                boolean isSorting,
                                                boolean noDataWindowSingleStream,
                                                AggregationGroupByRollupDesc groupByRollupDesc,
                                                boolean isJoin,
                                                boolean isHistoricalOnly,
                                                boolean iterateUnbounded,
                                                ResultSetProcessorOutputConditionType outputConditionType,
                                                OutputConditionPolledFactoryForge optionalOutputFirstConditionFactory,
                                                EventType[] eventTypes)

Method Detail

getResultEventType

public EventType getResultEventType()

isSorting

public boolean isSorting()

isSelectRStream

public boolean isSelectRStream()

isUnidirectional

public boolean isUnidirectional()

getOutputLimitSpec

public OutputLimitSpec getOutputLimitSpec()

getGroupKeyNodeExpressions

public ExprNode[] getGroupKeyNodeExpressions()

getGroupByRollupDesc

public AggregationGroupByRollupDesc getGroupByRollupDesc()

getPerLevelForges

public GroupByRollupPerLevelForge getPerLevelForges()

isJoin

public boolean isJoin()

isHistoricalOnly

public boolean isHistoricalOnly()

getOutputConditionType

public ResultSetProcessorOutputConditionType getOutputConditionType()

getNumStreams

public int getNumStreams()

getEventTypes

public EventType[] getEventTypes()

getInterfaceClass

public Class getInterfaceClass()

Specified by:

getInterfaceClass in interface ResultSetProcessorFactoryForge

getOptionalOutputFirstConditionFactory

public OutputConditionPolledFactoryForge getOptionalOutputFirstConditionFactory()

instanceCodegen

public void instanceCodegen(CodegenInstanceAux instance,
                            CodegenClassScope classScope,
                            CodegenCtor factoryCtor,
                            List<CodegenTypedParam> factoryMembers)

Specified by:

instanceCodegen in interface ResultSetProcessorFactoryForge

processViewResultCodegen

public void processViewResultCodegen(CodegenClassScope classScope,
                                     CodegenMethod method,
                                     CodegenInstanceAux instance)

Specified by:

processViewResultCodegen in interface ResultSetProcessorFactoryForge

processJoinResultCodegen

public void processJoinResultCodegen(CodegenClassScope classScope,
                                     CodegenMethod method,
                                     CodegenInstanceAux instance)

Specified by:

processJoinResultCodegen in interface ResultSetProcessorFactoryForge

getIteratorViewCodegen

public void getIteratorViewCodegen(CodegenClassScope classScope,
                                   CodegenMethod method,
                                   CodegenInstanceAux instance)

Specified by:

getIteratorViewCodegen in interface ResultSetProcessorFactoryForge

getIteratorJoinCodegen

public void getIteratorJoinCodegen(CodegenClassScope classScope,
                                   CodegenMethod method,
                                   CodegenInstanceAux instance)

Specified by:

getIteratorJoinCodegen in interface ResultSetProcessorFactoryForge

processOutputLimitedViewCodegen

public void processOutputLimitedViewCodegen(CodegenClassScope classScope,
                                            CodegenMethod method,
                                            CodegenInstanceAux instance)

Specified by:

processOutputLimitedViewCodegen in interface ResultSetProcessorFactoryForge

processOutputLimitedJoinCodegen

public void processOutputLimitedJoinCodegen(CodegenClassScope classScope,
                                            CodegenMethod method,
                                            CodegenInstanceAux instance)

Specified by:

processOutputLimitedJoinCodegen in interface ResultSetProcessorFactoryForge

applyViewResultCodegen

public void applyViewResultCodegen(CodegenClassScope classScope,
                                   CodegenMethod method,
                                   CodegenInstanceAux instance)

Specified by:

applyViewResultCodegen in interface ResultSetProcessorFactoryForge

applyJoinResultCodegen

public void applyJoinResultCodegen(CodegenClassScope classScope,
                                   CodegenMethod method,
                                   CodegenInstanceAux instance)

Specified by:

applyJoinResultCodegen in interface ResultSetProcessorFactoryForge

continueOutputLimitedLastAllNonBufferedViewCodegen

public void continueOutputLimitedLastAllNonBufferedViewCodegen(CodegenClassScope classScope,
                                                               CodegenMethod method,
                                                               CodegenInstanceAux instance)

Specified by:

continueOutputLimitedLastAllNonBufferedViewCodegen in interface ResultSetProcessorFactoryForge

continueOutputLimitedLastAllNonBufferedJoinCodegen

public void continueOutputLimitedLastAllNonBufferedJoinCodegen(CodegenClassScope classScope,
                                                               CodegenMethod method,
                                                               CodegenInstanceAux instance)

Specified by:

continueOutputLimitedLastAllNonBufferedJoinCodegen in interface ResultSetProcessorFactoryForge

processOutputLimitedLastAllNonBufferedViewCodegen

public void processOutputLimitedLastAllNonBufferedViewCodegen(CodegenClassScope classScope,
                                                              CodegenMethod method,
                                                              CodegenInstanceAux instance)

Specified by:

processOutputLimitedLastAllNonBufferedViewCodegen in interface ResultSetProcessorFactoryForge

processOutputLimitedLastAllNonBufferedJoinCodegen

public void processOutputLimitedLastAllNonBufferedJoinCodegen(CodegenClassScope classScope,
                                                              CodegenMethod method,
                                                              CodegenInstanceAux instance)

Specified by:

processOutputLimitedLastAllNonBufferedJoinCodegen in interface ResultSetProcessorFactoryForge

acceptHelperVisitorCodegen

public void acceptHelperVisitorCodegen(CodegenClassScope classScope,
                                       CodegenMethod method,
                                       CodegenInstanceAux instance)

Specified by:

acceptHelperVisitorCodegen in interface ResultSetProcessorFactoryForge

stopMethodCodegen

public void stopMethodCodegen(CodegenClassScope classScope,
                              CodegenMethod method,
                              CodegenInstanceAux instance)

Specified by:

stopMethodCodegen in interface ResultSetProcessorFactoryForge

clearMethodCodegen

public void clearMethodCodegen(CodegenClassScope classScope,
                               CodegenMethod method)

Specified by:

clearMethodCodegen in interface ResultSetProcessorFactoryForge

getGroupKeyTypes

public Class[] getGroupKeyTypes()

getInstrumentedQName

public String getInstrumentedQName()

Specified by:

getInstrumentedQName in interface ResultSetProcessorFactoryForge