public class ResultSetProcessorGroupedUtil extends Object
Modifier and Type | Field and Description |
---|---|
static String |
METHOD_APPLYAGGJOINRESULTKEYEDJOIN |
static String |
METHOD_APPLYAGGVIEWRESULTKEYEDVIEW |
Constructor and Description |
---|
ResultSetProcessorGroupedUtil() |
Modifier and Type | Method and Description |
---|---|
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
|
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
|
static 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) |
public static final String METHOD_APPLYAGGVIEWRESULTKEYEDVIEW
public static final String METHOD_APPLYAGGJOINRESULTKEYEDJOIN
public static void applyAggViewResultKeyedView(AggregationService aggregationService, ExprEvaluatorContext exprEvaluatorContext, EventBean[] newData, Object[] newDataMultiKey, EventBean[] oldData, Object[] oldDataMultiKey, EventBean[] eventsPerStream)
aggregationService
- aggsexprEvaluatorContext
- ctxnewData
- new datanewDataMultiKey
- new data keysoldData
- old dataoldDataMultiKey
- old data keyseventsPerStream
- event buffer, transient bufferpublic static void applyAggJoinResultKeyedJoin(AggregationService aggregationService, ExprEvaluatorContext exprEvaluatorContext, Set<MultiKeyArrayOfKeys<EventBean>> newEvents, Object[] newDataMultiKey, Set<MultiKeyArrayOfKeys<EventBean>> oldEvents, Object[] oldDataMultiKey)
aggregationService
- aggsexprEvaluatorContext
- ctxnewEvents
- new datanewDataMultiKey
- new data keysoldEvents
- old dataoldDataMultiKey
- old data keyspublic static CodegenMethod generateGroupKeySingleCodegen(ExprNode[] groupKeyExpressions, MultiKeyClassRef optionalMultiKeyClasses, CodegenClassScope classScope, CodegenInstanceAux instance)
public static CodegenMethod generateGroupKeyArrayViewCodegen(CodegenMethod generateGroupKeySingle, CodegenClassScope classScope, CodegenInstanceAux instance)
public static CodegenMethod generateGroupKeyArrayJoinCodegen(CodegenMethod generateGroupKeySingle, CodegenClassScope classScope, CodegenInstanceAux instance)
Copyright © 2005–2021. All rights reserved.