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

Class ResultSetProcessorRowPerGroupRollupForge

java.lang.Object

com.espertech.esper.common.internal.epl.resultset.core.ResultSetProcessorFactoryForgeBase

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

All Implemented Interfaces:

ResultSetProcessorFactoryForge

public class ResultSetProcessorRowPerGroupRollupForge
extends ResultSetProcessorFactoryForgeBase

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.

Field Summary

Fields inherited from class com.espertech.esper.common.internal.epl.resultset.core.ResultSetProcessorFactoryForgeBase

resultEventType, typesPerStream

Constructor Summary

Constructors

Constructor

Description

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

Method Summary

Modifier and Type	Method	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()
CodegenMethod	getGenerateGroupKeySingle()
AggregationGroupByRollupDescForge	getGroupByRollupDesc()
ExprNode[]	getGroupKeyNodeExpressions()
EPType[]	getGroupKeyTypes()
String	getInstrumentedQName()
EPTypeClass	getInterfaceClass()
void	getIteratorJoinCodegen(CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
void	getIteratorViewCodegen(CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
MultiKeyClassRef	getMultiKeyClassRef()
int	getNumStreams()
OutputConditionPolledFactoryForge	getOptionalOutputFirstConditionFactory()
StateMgmtSetting	getOutputAllSettings()
ResultSetProcessorOutputConditionType	getOutputConditionType()
StateMgmtSetting	getOutputFirstSettings()
StateMgmtSetting	getOutputLastSettings()
StateMgmtSetting	getOutputSnapshotSettings()
GroupByRollupPerLevelForge	getPerLevelForges()
void	instanceCodegen(CodegenInstanceAux instance, CodegenClassScope classScope, CodegenCtor factoryCtor, List<CodegenTypedParam> factoryMembers)
boolean	isHistoricalOnly()
boolean	isJoin()
boolean	isOutputAll()
boolean	isOutputDefault()
boolean	isOutputFirst()
boolean	isOutputLast()
boolean	isOutputSnapshot()
boolean	isSelectRStream()
boolean	isSorting()
boolean	isUnidirectional()
void	planStateSettings(FabricCharge fabricCharge, StatementRawInfo statementRawInfo, ResultSetProcessorFlags flags, StatementCompileTimeServices services)
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 com.espertech.esper.common.internal.epl.resultset.core.ResultSetProcessorFactoryForgeBase

getResultEventType, getTypesPerStream

Methods inherited from class java.lang.Object

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

Constructor Details

ResultSetProcessorRowPerGroupRollupForge

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

Method Details

isSorting

public boolean isSorting()

isSelectRStream

public boolean isSelectRStream()

isUnidirectional

public boolean isUnidirectional()

getGroupKeyNodeExpressions

public ExprNode[] getGroupKeyNodeExpressions()

getGroupByRollupDesc

public AggregationGroupByRollupDescForge 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 EPTypeClass getInterfaceClass()

getOptionalOutputFirstConditionFactory

public OutputConditionPolledFactoryForge getOptionalOutputFirstConditionFactory()

getMultiKeyClassRef

public MultiKeyClassRef getMultiKeyClassRef()

instanceCodegen

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

processViewResultCodegen

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

processJoinResultCodegen

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

getIteratorViewCodegen

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

getIteratorJoinCodegen

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

processOutputLimitedViewCodegen

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

processOutputLimitedJoinCodegen

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

applyViewResultCodegen

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

applyJoinResultCodegen

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

continueOutputLimitedLastAllNonBufferedViewCodegen

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

continueOutputLimitedLastAllNonBufferedJoinCodegen

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

processOutputLimitedLastAllNonBufferedViewCodegen

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

processOutputLimitedLastAllNonBufferedJoinCodegen

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

acceptHelperVisitorCodegen

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

stopMethodCodegen

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

clearMethodCodegen

public void clearMethodCodegen(CodegenClassScope classScope,
 CodegenMethod method)

getGroupKeyTypes

public EPType[] getGroupKeyTypes()

getInstrumentedQName

public String getInstrumentedQName()

getGenerateGroupKeySingle

public CodegenMethod getGenerateGroupKeySingle()

getOutputFirstSettings

public StateMgmtSetting getOutputFirstSettings()

getOutputAllSettings

public StateMgmtSetting getOutputAllSettings()

getOutputLastSettings

public StateMgmtSetting getOutputLastSettings()

getOutputSnapshotSettings

public StateMgmtSetting getOutputSnapshotSettings()

planStateSettings

public void planStateSettings(FabricCharge fabricCharge,
 StatementRawInfo statementRawInfo,
 ResultSetProcessorFlags flags,
 StatementCompileTimeServices services)

isOutputFirst

public boolean isOutputFirst()

isOutputLast

public boolean isOutputLast()

isOutputAll

public boolean isOutputAll()

isOutputSnapshot

public boolean isOutputSnapshot()

isOutputDefault

public boolean isOutputDefault()