com.espertech.esper.epl.agg.service.table

Class AggSvcGroupByWTableRollupMultiKeyImpl

java.lang.Object

com.espertech.esper.epl.agg.service.table.AggSvcGroupByWTableBase

com.espertech.esper.epl.agg.service.table.AggSvcGroupByWTableRollupMultiKeyImpl

All Implemented Interfaces:

AggregationResultFuture, AggregationService, StopCallback

public class AggSvcGroupByWTableRollupMultiKeyImpl
extends AggSvcGroupByWTableBase

Implementation for handling aggregation with grouping by group-keys.

Field Summary

Fields inherited from class com.espertech.esper.epl.agg.service.table.AggSvcGroupByWTableBase

accessors, accessStateExpr, currentAggregatorMethods, currentAggregatorStates, currentGroupKey, isJoin, methodPairs, tableMetadata, tableStateInstance, targetStates

Constructor Summary

Constructors

Constructor and Description
AggSvcGroupByWTableRollupMultiKeyImpl(TableMetadata tableMetadata, TableColumnMethodPair[] methodPairs, AggregationAccessorSlotPair[] accessors, boolean join, TableStateInstanceGrouped tableStateInstance, int[] targetStates, ExprNode[] accessStateExpr, AggregationAgent[] agents, AggregationGroupByRollupDesc groupByRollupDesc)

Method Summary

Modifier and Type	Method and Description
void	applyEnterInternal(EventBean[] eventsPerStream, java.lang.Object compositeGroupByKey, ExprEvaluatorContext exprEvaluatorContext)
void	applyLeaveInternal(EventBean[] eventsPerStream, java.lang.Object compositeGroupByKey, ExprEvaluatorContext exprEvaluatorContext)
static CodegenMethodNode	applyRollupCodegen(boolean enter, CodegenMethodNode parent, CodegenClassScope classScope, CodegenNamedMethods namedMethods, TableColumnMethodPair[] methodPairs, AggregationAgentForge[] agentForges, AggregationAgent[] agents, int[] targetStates, AggregationGroupByRollupDesc groupByRollupDesc, int numTableKeys)
void	setCurrentAccess(java.lang.Object groupByKey, int agentInstanceId, AggregationGroupByRollupLevel rollupLevel) Set the current aggregation state row - for use when evaluation nodes are asked to evaluate.
static void	setCurrentAccessRollupCodegen(CodegenMethodNode method, CodegenClassScope classScope, int numTableKeys)

Methods inherited from class com.espertech.esper.epl.agg.service.table.AggSvcGroupByWTableBase

accept, acceptGroupDetail, applyEnter, applyEnterGroupKey, applyGroupKeyCodegen, applyLeave, applyLeaveGroupKey, clearResults, ctorCodegen, getCollectionOfEvents, getCollectionScalar, getContextPartitionAggregationService, getEventBean, getGroupByValueCodegen, getGroupKey, getGroupKeys, getValue, isGrouped, setCurrentAccessCodegen, setRemovedCallback, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

AggSvcGroupByWTableRollupMultiKeyImpl

public AggSvcGroupByWTableRollupMultiKeyImpl(TableMetadata tableMetadata,
                                             TableColumnMethodPair[] methodPairs,
                                             AggregationAccessorSlotPair[] accessors,
                                             boolean join,
                                             TableStateInstanceGrouped tableStateInstance,
                                             int[] targetStates,
                                             ExprNode[] accessStateExpr,
                                             AggregationAgent[] agents,
                                             AggregationGroupByRollupDesc groupByRollupDesc)

Method Detail

applyEnterInternal

public void applyEnterInternal(EventBean[] eventsPerStream,
                               java.lang.Object compositeGroupByKey,
                               ExprEvaluatorContext exprEvaluatorContext)

Specified by:

applyEnterInternal in class AggSvcGroupByWTableBase

applyLeaveInternal

public void applyLeaveInternal(EventBean[] eventsPerStream,
                               java.lang.Object compositeGroupByKey,
                               ExprEvaluatorContext exprEvaluatorContext)

Specified by:

applyLeaveInternal in class AggSvcGroupByWTableBase

applyRollupCodegen

public static CodegenMethodNode applyRollupCodegen(boolean enter,
                                                   CodegenMethodNode parent,
                                                   CodegenClassScope classScope,
                                                   CodegenNamedMethods namedMethods,
                                                   TableColumnMethodPair[] methodPairs,
                                                   AggregationAgentForge[] agentForges,
                                                   AggregationAgent[] agents,
                                                   int[] targetStates,
                                                   AggregationGroupByRollupDesc groupByRollupDesc,
                                                   int numTableKeys)

setCurrentAccess

public void setCurrentAccess(java.lang.Object groupByKey,
                             int agentInstanceId,
                             AggregationGroupByRollupLevel rollupLevel)

Description copied from interface: AggregationService

Set the current aggregation state row - for use when evaluation nodes are asked to evaluate.

Specified by:

setCurrentAccess in interface AggregationService

Overrides:

setCurrentAccess in class AggSvcGroupByWTableBase

Parameters:

groupByKey - - single key identifying the row of aggregation states

agentInstanceId - context partition id

rollupLevel - rollup level

setCurrentAccessRollupCodegen

public static void setCurrentAccessRollupCodegen(CodegenMethodNode method,
                                                 CodegenClassScope classScope,
                                                 int numTableKeys)