Class ResultSetProcessorRowPerEventImpl
java.lang.Object
com.espertech.esper.common.internal.epl.resultset.rowperevent.ResultSetProcessorRowPerEventImpl
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
-
Method Summary
Modifier and TypeMethodDescriptionstatic 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)
-
Constructor Details
-
ResultSetProcessorRowPerEventImpl
public ResultSetProcessorRowPerEventImpl()
-
-
Method Details
-
applyViewResultCodegen
-
applyJoinResultCodegen
-
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
-
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
-