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

java.lang.Object
  com.espertech.esper.epl.agg.service.AggSvcGroupByWTableBase
      com.espertech.esper.epl.agg.service.AggSvcGroupByWTableRollupMultiKeyImpl

All Implemented Interfaces:

AggregationResultFuture, AggregationService

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.AggSvcGroupByWTableBase

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

Constructor Summary

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

Method Summary

void	applyEnterInternal(EventBean[] eventsPerStream, java.lang.Object compositeGroupByKey, ExprEvaluatorContext exprEvaluatorContext)
void	applyLeaveInternal(EventBean[] eventsPerStream, java.lang.Object compositeGroupByKey, ExprEvaluatorContext exprEvaluatorContext)
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.

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

accept, acceptGroupDetail, applyEnter, applyEnterGroupKey, applyLeave, applyLeaveGroupKey, clearResults, getCollectionOfEvents, getCollectionScalar, getEventBean, getGroupKey, getGroupKeys, getValue, isGrouped, setRemovedCallback

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,
                                             TableStateInstanceGroupBy 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

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