Class ResultSetProcessorRowForAllImpl
java.lang.Object
com.espertech.esper.common.internal.epl.resultset.rowforall.ResultSetProcessorRowForAllImpl
Result set processor for the case: aggregation functions used in the select clause, and no group-by,
and all 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. Produces one old event and one new event row every time either at least one old or new event is received. 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
continueOutputLimitedLastAllNonBufferedJoinCodegen
(ResultSetProcessorRowForAllForge forge, CodegenMethod method) static void
continueOutputLimitedLastAllNonBufferedViewCodegen
(ResultSetProcessorRowForAllForge forge, CodegenMethod method) static void
getIteratorJoinCodegen
(ResultSetProcessorRowForAllForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance) static void
processJoinResultCodegen
(ResultSetProcessorRowForAllForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instanceMethods) static void
processOutputLimitedJoinCodegen
(ResultSetProcessorRowForAllForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance) static void
processOutputLimitedLastAllNonBufferedJoinCodegen
(ResultSetProcessorRowForAllForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance) static void
processOutputLimitedLastAllNonBufferedViewCodegen
(ResultSetProcessorRowForAllForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance) static void
processOutputLimitedViewCodegen
(ResultSetProcessorRowForAllForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance) static void
processViewResultCodegen
(ResultSetProcessorRowForAllForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance)
-
Constructor Details
-
ResultSetProcessorRowForAllImpl
public ResultSetProcessorRowForAllImpl()
-
-
Method Details
-
processJoinResultCodegen
public static void processJoinResultCodegen(ResultSetProcessorRowForAllForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instanceMethods) -
processViewResultCodegen
public static void processViewResultCodegen(ResultSetProcessorRowForAllForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance) -
getIteratorJoinCodegen
public static void getIteratorJoinCodegen(ResultSetProcessorRowForAllForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance) -
processOutputLimitedJoinCodegen
public static void processOutputLimitedJoinCodegen(ResultSetProcessorRowForAllForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance) -
processOutputLimitedViewCodegen
public static void processOutputLimitedViewCodegen(ResultSetProcessorRowForAllForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance) -
applyViewResultCodegen
-
applyJoinResultCodegen
-
processOutputLimitedLastAllNonBufferedViewCodegen
public static void processOutputLimitedLastAllNonBufferedViewCodegen(ResultSetProcessorRowForAllForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance) -
processOutputLimitedLastAllNonBufferedJoinCodegen
public static void processOutputLimitedLastAllNonBufferedJoinCodegen(ResultSetProcessorRowForAllForge forge, CodegenClassScope classScope, CodegenMethod method, CodegenInstanceAux instance) -
continueOutputLimitedLastAllNonBufferedViewCodegen
public static void continueOutputLimitedLastAllNonBufferedViewCodegen(ResultSetProcessorRowForAllForge forge, CodegenMethod method) -
continueOutputLimitedLastAllNonBufferedJoinCodegen
public static void continueOutputLimitedLastAllNonBufferedJoinCodegen(ResultSetProcessorRowForAllForge forge, CodegenMethod method) -
acceptHelperVisitorCodegen
-