com.espertech.esper.common.internal.epl.agg.table

Class AggSvcGroupByWTableRollupMultiKeyImpl

java.lang.Object

com.espertech.esper.common.internal.epl.agg.table.AggSvcGroupByWTableBase

com.espertech.esper.common.internal.epl.agg.table.AggSvcGroupByWTableRollupMultiKeyImpl

All Implemented Interfaces:

AggregationResultFuture, AggregationService, AggregationServiceTable, StopCallback

public class AggSvcGroupByWTableRollupMultiKeyImpl
extends AggSvcGroupByWTableBase

Implementation for handling aggregation with grouping by group-keys.

Field Summary

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

currentAggregationRow, currentGroupKey, methodPairs, tableInstance

Constructor Summary

Constructors

Constructor and Description
AggSvcGroupByWTableRollupMultiKeyImpl(TableInstanceGrouped tableInstance, TableColumnMethodPairEval[] methodPairs, AggregationMultiFunctionAgent[] accessAgents, int[] accessColumnsZeroOffset, AggregationGroupByRollupDesc groupByRollupDesc)

Method Summary

Modifier and Type	Method and Description
void	applyEnterInternal(EventBean[] eventsPerStream, Object compositeGroupByKey, ExprEvaluatorContext exprEvaluatorContext)
void	applyLeaveInternal(EventBean[] eventsPerStream, Object compositeGroupByKey, ExprEvaluatorContext exprEvaluatorContext)
void	setCurrentAccess(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.common.internal.epl.agg.table.AggSvcGroupByWTableBase

accept, acceptGroupDetail, applyEnter, applyEnterGroupKey, applyLeave, applyLeaveGroupKey, clearResults, getCollectionOfEvents, getCollectionScalar, getContextPartitionAggregationService, getEventBean, getGroupKey, getGroupKeys, getTableInstance, getValue, isGrouped, 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(TableInstanceGrouped tableInstance,
                                             TableColumnMethodPairEval[] methodPairs,
                                             AggregationMultiFunctionAgent[] accessAgents,
                                             int[] accessColumnsZeroOffset,
                                             AggregationGroupByRollupDesc groupByRollupDesc)

Method Detail

applyEnterInternal

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

Specified by:

applyEnterInternal in class AggSvcGroupByWTableBase

applyLeaveInternal

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

Specified by:

applyLeaveInternal in class AggSvcGroupByWTableBase

setCurrentAccess

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

Description copied from interface: AggregationResultFuture

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

Specified by:

setCurrentAccess in interface AggregationResultFuture

Overrides:

setCurrentAccess in class AggSvcGroupByWTableBase

Parameters:

groupByKey - - single key identifying the row of aggregation states

agentInstanceId - context partition id

rollupLevel - rollup level