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

Class ResultSetProcessorRowPerEventImpl

java.lang.Object

com.espertech.esper.common.internal.epl.resultset.rowperevent.ResultSetProcessorRowPerEventImpl

public class ResultSetProcessorRowPerEventImpl
extends Object

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

This processor does not perform grouping, every event entering and leaving is in the same group. The processor generates one row for each event entering (new event) and one row for each event leaving (old event). Aggregation state is simply one row holding all the state.

Constructor Summary

Constructors

Constructor and Description
ResultSetProcessorRowPerEventImpl()

Method Summary

Modifier and Type	Method and Description
static void	acceptHelperVisitorCodegen(CodegenMethod method, CodegenInstanceAux instance)
static void	applyJoinResultCodegen(CodegenMethod method)
static void	applyViewResultCodegen(CodegenMethod method)
static void	clearMethodCodegen(CodegenMethod method)
static void	continueOutputLimitedLastAllNonBufferedJoinCodegen(ResultSetProcessorRowPerEventForge forge, CodegenMethod method)
static void	continueOutputLimitedLastAllNonBufferedViewCodegen(ResultSetProcessorRowPerEventForge forge, CodegenMethod method)
static void	getIteratorJoinCodegen(ResultSetProcessorRowPerEventForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
static void	getIteratorViewCodegen(ResultSetProcessorRowPerEventForge forge, CodegenClassScope classScope, CodegenMethod method)
static void	processJoinResultCodegen(ResultSetProcessorRowPerEventForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
static void	processOutputLimitedJoinCodegen(ResultSetProcessorRowPerEventForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
static void	processOutputLimitedLastAllNonBufferedJoinCodegen(ResultSetProcessorRowPerEventForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
static void	processOutputLimitedLastAllNonBufferedViewCodegen(ResultSetProcessorRowPerEventForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
static void	processOutputLimitedViewCodegen(ResultSetProcessorRowPerEventForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
static void	processViewResultCodegen(ResultSetProcessorRowPerEventForge forge, 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

ResultSetProcessorRowPerEventImpl

public ResultSetProcessorRowPerEventImpl()

Method Detail

applyViewResultCodegen

public static void applyViewResultCodegen(CodegenMethod method)

applyJoinResultCodegen

public static void applyJoinResultCodegen(CodegenMethod method)

processJoinResultCodegen

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

processViewResultCodegen

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

getIteratorViewCodegen

public static void getIteratorViewCodegen(ResultSetProcessorRowPerEventForge forge,
                                          CodegenClassScope classScope,
                                          CodegenMethod method)

getIteratorJoinCodegen

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

clearMethodCodegen

public static void clearMethodCodegen(CodegenMethod method)

processOutputLimitedJoinCodegen

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

processOutputLimitedViewCodegen

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

processOutputLimitedLastAllNonBufferedViewCodegen

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

processOutputLimitedLastAllNonBufferedJoinCodegen

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

continueOutputLimitedLastAllNonBufferedViewCodegen

public static void continueOutputLimitedLastAllNonBufferedViewCodegen(ResultSetProcessorRowPerEventForge forge,
                                                                      CodegenMethod method)

continueOutputLimitedLastAllNonBufferedJoinCodegen

public static void continueOutputLimitedLastAllNonBufferedJoinCodegen(ResultSetProcessorRowPerEventForge forge,
                                                                      CodegenMethod method)

acceptHelperVisitorCodegen

public static void acceptHelperVisitorCodegen(CodegenMethod method,
                                              CodegenInstanceAux instance)