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

Class ResultSetProcessorRowPerGroupImpl

java.lang.Object

com.espertech.esper.common.internal.epl.resultset.rowpergroup.ResultSetProcessorRowPerGroupImpl

public class ResultSetProcessorRowPerGroupImpl
extends Object

Result set processor 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.

Produces one row for each group that changed (and not one row per event). Computes MultiKey group-by keys for each event and uses a set of the group-by keys to generate the result rows, using the first (old or new, anyone) event for each distinct group-by key.

Constructor Summary

Constructors

Constructor and Description
ResultSetProcessorRowPerGroupImpl()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

ResultSetProcessorRowPerGroupImpl

public ResultSetProcessorRowPerGroupImpl()

Method Detail

applyViewResultCodegen

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

applyJoinResultCodegen

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

processJoinResultCodegen

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

processViewResultCodegen

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

getIteratorViewCodegen

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

getIteratorJoinCodegen

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

clearMethodCodegen

public static void clearMethodCodegen(CodegenMethod method)

processOutputLimitedJoinCodegen

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

processOutputLimitedViewCodegen

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

processOutputLimitedLastAllNonBufferedViewCodegen

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

processOutputLimitedLastAllNonBufferedJoinCodegen

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

continueOutputLimitedLastAllNonBufferedViewCodegen

public static void continueOutputLimitedLastAllNonBufferedViewCodegen(ResultSetProcessorRowPerGroupForge forge,
                                                                      CodegenMethod method)

continueOutputLimitedLastAllNonBufferedJoinCodegen

public static void continueOutputLimitedLastAllNonBufferedJoinCodegen(ResultSetProcessorRowPerGroupForge forge,
                                                                      CodegenMethod method)

stopMethodCodegenBound

public static void stopMethodCodegenBound(CodegenMethod method,
                                          CodegenInstanceAux instance)

acceptHelperVisitorCodegen

public static void acceptHelperVisitorCodegen(CodegenMethod method,
                                              CodegenInstanceAux instance)