com.espertech.esper.common.internal.epl.resultset.grouped

Class ResultSetProcessorGroupedUtil

java.lang.Object

com.espertech.esper.common.internal.epl.resultset.grouped.ResultSetProcessorGroupedUtil

public class ResultSetProcessorGroupedUtil
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	METHOD_APPLYAGGJOINRESULTKEYEDJOIN
static String	METHOD_APPLYAGGVIEWRESULTKEYEDVIEW

Constructor Summary

Constructors

Constructor and Description
ResultSetProcessorGroupedUtil()

Method Summary

Modifier and Type	Method and Description
static void	applyAggJoinResultKeyedJoin(AggregationService aggregationService, AgentInstanceContext agentInstanceContext, Set<MultiKey<EventBean>> newEvents, Object[] newDataMultiKey, Set<MultiKey<EventBean>> oldEvents, Object[] oldDataMultiKey) NOTE: Code-generation-invoked method, method name and parameter order matters
static void	applyAggViewResultKeyedView(AggregationService aggregationService, AgentInstanceContext agentInstanceContext, EventBean[] newData, Object[] newDataMultiKey, EventBean[] oldData, Object[] oldDataMultiKey, EventBean[] eventsPerStream) NOTE: Code-generation-invoked method, method name and parameter order matters
static CodegenMethod	generateGroupKeyArrayJoinCodegen(ExprNode[] groupKeyExpressions, CodegenClassScope classScope, CodegenInstanceAux instance)
static CodegenMethod	generateGroupKeyArrayViewCodegen(ExprNode[] groupKeyExpressions, CodegenClassScope classScope, CodegenInstanceAux instance)
static CodegenMethod	generateGroupKeySingleCodegen(ExprNode[] groupKeyExpressions, CodegenClassScope classScope, CodegenInstanceAux instance)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

METHOD_APPLYAGGVIEWRESULTKEYEDVIEW

public static final String METHOD_APPLYAGGVIEWRESULTKEYEDVIEW

See Also:

Constant Field Values

METHOD_APPLYAGGJOINRESULTKEYEDJOIN

public static final String METHOD_APPLYAGGJOINRESULTKEYEDJOIN

See Also:

Constant Field Values

Constructor Detail

ResultSetProcessorGroupedUtil

public ResultSetProcessorGroupedUtil()

Method Detail

applyAggViewResultKeyedView

public static void applyAggViewResultKeyedView(AggregationService aggregationService,
                                               AgentInstanceContext agentInstanceContext,
                                               EventBean[] newData,
                                               Object[] newDataMultiKey,
                                               EventBean[] oldData,
                                               Object[] oldDataMultiKey,
                                               EventBean[] eventsPerStream)

NOTE: Code-generation-invoked method, method name and parameter order matters

Parameters:

aggregationService - aggs

agentInstanceContext - ctx

newData - new data

newDataMultiKey - new data keys

oldData - old data

oldDataMultiKey - old data keys

eventsPerStream - event buffer, transient buffer

applyAggJoinResultKeyedJoin

public static void applyAggJoinResultKeyedJoin(AggregationService aggregationService,
                                               AgentInstanceContext agentInstanceContext,
                                               Set<MultiKey<EventBean>> newEvents,
                                               Object[] newDataMultiKey,
                                               Set<MultiKey<EventBean>> oldEvents,
                                               Object[] oldDataMultiKey)

NOTE: Code-generation-invoked method, method name and parameter order matters

Parameters:

aggregationService - aggs

agentInstanceContext - ctx

newEvents - new data

newDataMultiKey - new data keys

oldEvents - old data

oldDataMultiKey - old data keys

generateGroupKeySingleCodegen

public static CodegenMethod generateGroupKeySingleCodegen(ExprNode[] groupKeyExpressions,
                                                          CodegenClassScope classScope,
                                                          CodegenInstanceAux instance)

generateGroupKeyArrayViewCodegen

public static CodegenMethod generateGroupKeyArrayViewCodegen(ExprNode[] groupKeyExpressions,
                                                             CodegenClassScope classScope,
                                                             CodegenInstanceAux instance)

generateGroupKeyArrayJoinCodegen

public static CodegenMethod generateGroupKeyArrayJoinCodegen(ExprNode[] groupKeyExpressions,
                                                             CodegenClassScope classScope,
                                                             CodegenInstanceAux instance)