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

Class AggSvcGroupByWTableImpl

java.lang.Object

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

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

All Implemented Interfaces:

AggregationResultFuture, AggregationService, AggregationServiceTable, StopCallback

public class AggSvcGroupByWTableImpl
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
AggSvcGroupByWTableImpl(TableInstanceGrouped table, TableColumnMethodPairEval[] methodPairs, AggregationMultiFunctionAgent[] accessAgents, int[] accessColumnsZeroOffset)

Method Summary

Modifier and Type	Method	Description
void	applyEnterInternal(EventBean[] eventsPerStream, Object groupByKey, ExprEvaluatorContext exprEvaluatorContext)
void	applyLeaveInternal(EventBean[] eventsPerStream, Object groupByKey, 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

AggSvcGroupByWTableImpl

public AggSvcGroupByWTableImpl(TableInstanceGrouped table,
 TableColumnMethodPairEval[] methodPairs,
 AggregationMultiFunctionAgent[] accessAgents,
 int[] accessColumnsZeroOffset)

Method Details

applyEnterInternal

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

Specified by:

applyEnterInternal in class AggSvcGroupByWTableBase

applyLeaveInternal

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

Specified by:

applyLeaveInternal in class AggSvcGroupByWTableBase