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

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

All Implemented Interfaces:

AggregationResultFuture, AggregationService

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

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

Method Summary

void	applyEnterInternal(EventBean[] eventsPerStream, java.lang.Object groupByKey, ExprEvaluatorContext exprEvaluatorContext)
void	applyLeaveInternal(EventBean[] eventsPerStream, java.lang.Object groupByKey, ExprEvaluatorContext exprEvaluatorContext)

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, setCurrentAccess, setRemovedCallback

Methods inherited from class java.lang.Object

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

Constructor Detail

AggSvcGroupByWTableImpl

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

Method Detail

applyEnterInternal

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

Specified by:

applyEnterInternal in class AggSvcGroupByWTableBase

applyLeaveInternal

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

Specified by:

applyLeaveInternal in class AggSvcGroupByWTableBase