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

Class ResultSetProcessorAggregateGroupedImpl

java.lang.Object

com.espertech.esper.common.internal.epl.resultset.agggrouped.ResultSetProcessorAggregateGroupedImpl

public class ResultSetProcessorAggregateGroupedImpl
extends Object

Result-set processor for the aggregate-grouped case: there is a group-by and one or more non-aggregation event properties in the select clause are not listed in the group by, and there are aggregation functions.

This processor does perform grouping by computing MultiKey group-by keys for each row. The processor generates one row for each event entering (new event) and one row for each event leaving (old event).

Aggregation state is a table of rows held by aggegation service where the row key is the group-by MultiKey.

Constructor Summary

Constructors

Constructor	Description
ResultSetProcessorAggregateGroupedImpl()

Method Summary

Modifier and Type	Method	Description
static void	acceptHelperVisitorCodegen(CodegenMethod method, CodegenInstanceAux instance)
static void	applyJoinResultCodegen(ResultSetProcessorAggregateGroupedForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
static void	applyViewResultCodegen(ResultSetProcessorAggregateGroupedForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
static void	clearMethodCodegen(CodegenMethod method)
static void	continueOutputLimitedLastAllNonBufferedJoinCodegen(ResultSetProcessorAggregateGroupedForge forge, CodegenMethod method)
static void	continueOutputLimitedLastAllNonBufferedViewCodegen(ResultSetProcessorAggregateGroupedForge forge, CodegenMethod method)
static void	getIteratorJoinCodegen(ResultSetProcessorAggregateGroupedForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
static void	getIteratorViewCodegen(ResultSetProcessorAggregateGroupedForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
static void	processJoinResultCodegen(ResultSetProcessorAggregateGroupedForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
static void	processOutputLimitedJoinCodegen(ResultSetProcessorAggregateGroupedForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
static void	processOutputLimitedLastAllNonBufferedJoinCodegen(ResultSetProcessorAggregateGroupedForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
static void	processOutputLimitedLastAllNonBufferedViewCodegen(ResultSetProcessorAggregateGroupedForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
static void	processOutputLimitedViewCodegen(ResultSetProcessorAggregateGroupedForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
static void	processViewResultCodegen(ResultSetProcessorAggregateGroupedForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
static void	stopMethodCodegen(CodegenMethod method, CodegenInstanceAux instance)

Methods inherited from class java.lang.Object

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

Constructor Details

ResultSetProcessorAggregateGroupedImpl

public ResultSetProcessorAggregateGroupedImpl()

Method Details

applyViewResultCodegen

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

applyJoinResultCodegen

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

processJoinResultCodegen

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

processViewResultCodegen

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

acceptHelperVisitorCodegen

public static void acceptHelperVisitorCodegen(CodegenMethod method,
 CodegenInstanceAux instance)

getIteratorViewCodegen

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

getIteratorJoinCodegen

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

clearMethodCodegen

public static void clearMethodCodegen(CodegenMethod method)

processOutputLimitedJoinCodegen

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

processOutputLimitedViewCodegen

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

stopMethodCodegen

public static void stopMethodCodegen(CodegenMethod method,
 CodegenInstanceAux instance)

processOutputLimitedLastAllNonBufferedViewCodegen

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

processOutputLimitedLastAllNonBufferedJoinCodegen

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

continueOutputLimitedLastAllNonBufferedViewCodegen

public static void continueOutputLimitedLastAllNonBufferedViewCodegen(ResultSetProcessorAggregateGroupedForge forge,
 CodegenMethod method)

continueOutputLimitedLastAllNonBufferedJoinCodegen

public static void continueOutputLimitedLastAllNonBufferedJoinCodegen(ResultSetProcessorAggregateGroupedForge forge,
 CodegenMethod method)