com.espertech.esper.epl.agg.service

Class AggSvcGroupByWTableRollupSingleKeyImpl

java.lang.Object

com.espertech.esper.epl.agg.service.AggSvcGroupByWTableBase

com.espertech.esper.epl.agg.service.AggSvcGroupByWTableRollupSingleKeyImpl

All Implemented Interfaces:

AggregationResultFuture, AggregationService, StopCallback

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

Constructors

Constructor and Description
AggSvcGroupByWTableRollupSingleKeyImpl(TableMetadata tableMetadata, TableColumnMethodPair[] methodPairs, AggregationAccessorSlotPair[] accessors, boolean join, TableStateInstanceGrouped tableStateInstance, int[] targetStates, ExprNode[] accessStateExpr, AggregationAgent[] agents)

Method Summary

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

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

AggSvcGroupByWTableRollupSingleKeyImpl

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

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