Class ResultSetProcessorGroupedUtil
java.lang.Object
com.espertech.esper.common.internal.epl.resultset.grouped.ResultSetProcessorGroupedUtil
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic void
applyAggJoinResultKeyedJoin
(AggregationService aggregationService, ExprEvaluatorContext exprEvaluatorContext, Set<MultiKeyArrayOfKeys<EventBean>> newEvents, Object[] newDataMultiKey, Set<MultiKeyArrayOfKeys<EventBean>> oldEvents, Object[] oldDataMultiKey) NOTE: Code-generation-invoked method, method name and parameter order mattersstatic void
applyAggViewResultKeyedView
(AggregationService aggregationService, ExprEvaluatorContext exprEvaluatorContext, EventBean[] newData, Object[] newDataMultiKey, EventBean[] oldData, Object[] oldDataMultiKey, EventBean[] eventsPerStream) NOTE: Code-generation-invoked method, method name and parameter order mattersstatic CodegenMethod
generateGroupKeyArrayJoinCodegen
(CodegenMethod generateGroupKeySingle, CodegenClassScope classScope, CodegenInstanceAux instance) static CodegenMethod
generateGroupKeyArrayViewCodegen
(CodegenMethod generateGroupKeySingle, CodegenClassScope classScope, CodegenInstanceAux instance) static CodegenMethod
generateGroupKeySingleCodegen
(ExprNode[] groupKeyExpressions, MultiKeyClassRef optionalMultiKeyClasses, CodegenClassScope classScope, CodegenInstanceAux instance)
-
Field Details
-
METHOD_APPLYAGGVIEWRESULTKEYEDVIEW
- See Also:
-
METHOD_APPLYAGGJOINRESULTKEYEDJOIN
- See Also:
-
-
Constructor Details
-
ResultSetProcessorGroupedUtil
public ResultSetProcessorGroupedUtil()
-
-
Method Details
-
applyAggViewResultKeyedView
public static void applyAggViewResultKeyedView(AggregationService aggregationService, ExprEvaluatorContext exprEvaluatorContext, EventBean[] newData, Object[] newDataMultiKey, EventBean[] oldData, Object[] oldDataMultiKey, EventBean[] eventsPerStream) NOTE: Code-generation-invoked method, method name and parameter order matters- Parameters:
aggregationService
- aggsexprEvaluatorContext
- ctxnewData
- new datanewDataMultiKey
- new data keysoldData
- old dataoldDataMultiKey
- old data keyseventsPerStream
- event buffer, transient buffer
-
applyAggJoinResultKeyedJoin
public static void applyAggJoinResultKeyedJoin(AggregationService aggregationService, ExprEvaluatorContext exprEvaluatorContext, Set<MultiKeyArrayOfKeys<EventBean>> newEvents, Object[] newDataMultiKey, Set<MultiKeyArrayOfKeys<EventBean>> oldEvents, Object[] oldDataMultiKey) NOTE: Code-generation-invoked method, method name and parameter order matters- Parameters:
aggregationService
- aggsexprEvaluatorContext
- ctxnewEvents
- new datanewDataMultiKey
- new data keysoldEvents
- old dataoldDataMultiKey
- old data keys
-
generateGroupKeySingleCodegen
public static CodegenMethod generateGroupKeySingleCodegen(ExprNode[] groupKeyExpressions, MultiKeyClassRef optionalMultiKeyClasses, CodegenClassScope classScope, CodegenInstanceAux instance) -
generateGroupKeyArrayViewCodegen
public static CodegenMethod generateGroupKeyArrayViewCodegen(CodegenMethod generateGroupKeySingle, CodegenClassScope classScope, CodegenInstanceAux instance) -
generateGroupKeyArrayJoinCodegen
public static CodegenMethod generateGroupKeyArrayJoinCodegen(CodegenMethod generateGroupKeySingle, CodegenClassScope classScope, CodegenInstanceAux instance)
-