public class ResultSetProcessorGroupedUtil
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
METHOD_APPLYAGGJOINRESULTKEYEDJOIN |
static java.lang.String |
METHOD_APPLYAGGVIEWRESULTKEYEDVIEW |
Constructor and Description |
---|
ResultSetProcessorGroupedUtil() |
Modifier and Type | Method and Description |
---|---|
static void |
applyAggJoinResultKeyedJoin(AggregationService aggregationService,
AgentInstanceContext agentInstanceContext,
java.util.Set<MultiKey<EventBean>> newEvents,
java.lang.Object[] newDataMultiKey,
java.util.Set<MultiKey<EventBean>> oldEvents,
java.lang.Object[] oldDataMultiKey)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
static void |
applyAggViewResultKeyedView(AggregationService aggregationService,
AgentInstanceContext agentInstanceContext,
EventBean[] newData,
java.lang.Object[] newDataMultiKey,
EventBean[] oldData,
java.lang.Object[] oldDataMultiKey,
EventBean[] eventsPerStream)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
static CodegenMethodNode |
generateGroupKeyArrayJoinCodegen(ExprNode[] groupKeyExpressions,
CodegenClassScope classScope,
CodegenInstanceAux instance) |
static CodegenMethodNode |
generateGroupKeyArrayViewCodegen(ExprNode[] groupKeyExpressions,
CodegenClassScope classScope,
CodegenInstanceAux instance) |
static CodegenMethodNode |
generateGroupKeySingleCodegen(ExprNode[] groupKeyExpressions,
CodegenClassScope classScope,
CodegenInstanceAux instance) |
public static final java.lang.String METHOD_APPLYAGGVIEWRESULTKEYEDVIEW
public static final java.lang.String METHOD_APPLYAGGJOINRESULTKEYEDJOIN
public static void applyAggViewResultKeyedView(AggregationService aggregationService, AgentInstanceContext agentInstanceContext, EventBean[] newData, java.lang.Object[] newDataMultiKey, EventBean[] oldData, java.lang.Object[] oldDataMultiKey, EventBean[] eventsPerStream)
aggregationService
- aggsagentInstanceContext
- ctxnewData
- new datanewDataMultiKey
- new data keysoldData
- old dataoldDataMultiKey
- old data keyseventsPerStream
- event buffer, transient bufferpublic static void applyAggJoinResultKeyedJoin(AggregationService aggregationService, AgentInstanceContext agentInstanceContext, java.util.Set<MultiKey<EventBean>> newEvents, java.lang.Object[] newDataMultiKey, java.util.Set<MultiKey<EventBean>> oldEvents, java.lang.Object[] oldDataMultiKey)
aggregationService
- aggsagentInstanceContext
- ctxnewEvents
- new datanewDataMultiKey
- new data keysoldEvents
- old dataoldDataMultiKey
- old data keyspublic static CodegenMethodNode generateGroupKeySingleCodegen(ExprNode[] groupKeyExpressions, CodegenClassScope classScope, CodegenInstanceAux instance)
public static CodegenMethodNode generateGroupKeyArrayViewCodegen(ExprNode[] groupKeyExpressions, CodegenClassScope classScope, CodegenInstanceAux instance)
public static CodegenMethodNode generateGroupKeyArrayJoinCodegen(ExprNode[] groupKeyExpressions, CodegenClassScope classScope, CodegenInstanceAux instance)