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

Class AggSvcGroupByWTableRollupSingleKeyImpl

java.lang.Object

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

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

All Implemented Interfaces:

AggregationResultFuture, AggregationService, AggregationServiceTable, StopCallback

public class AggSvcGroupByWTableRollupSingleKeyImpl
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

Fields inherited from interface com.espertech.esper.common.internal.epl.agg.core.AggregationService

EPTYPE

Constructor Summary

Constructors

Constructor	Description
AggSvcGroupByWTableRollupSingleKeyImpl(TableInstanceGrouped tableInstance, TableColumnMethodPairEval[] methodPairs, AggregationMultiFunctionAgent[] accessAgents, int[] accessColumnsZeroOffset)

Method Summary

Modifier and Type	Method	Description
void	applyEnterInternal(EventBean[] eventsPerStream, Object compositeGroupByKey, ExprEvaluatorContext exprEvaluatorContext)
void	applyLeaveInternal(EventBean[] eventsPerStream, Object compositeGroupByKey, ExprEvaluatorContext exprEvaluatorContext)

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

accept, acceptGroupDetail, applyEnter, applyEnterTableKey, applyLeave, applyLeaveTableKey, clearResults, getAggregationRow, getCollectionOfEvents, getCollectionScalar, getContextPartitionAggregationService, getEventBean, getGroupKey, getGroupKeys, getTableInstance, getValue, isGrouped, setCurrentAccess, setRemovedCallback, stop

Methods inherited from class java.lang.Object

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

Constructor Details

AggSvcGroupByWTableRollupSingleKeyImpl

public AggSvcGroupByWTableRollupSingleKeyImpl(TableInstanceGrouped tableInstance,
 TableColumnMethodPairEval[] methodPairs,
 AggregationMultiFunctionAgent[] accessAgents,
 int[] accessColumnsZeroOffset)

Method Details

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