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

java.lang.Object
  com.espertech.esper.epl.agg.service.AggregationServiceBaseGrouped

All Implemented Interfaces:

AggregationResultFuture, AggregationService, StopCallback

Direct Known Subclasses:

AggSvcGroupByMixedAccessImpl, AggSvcGroupByNoAccessImpl, AggSvcGroupByReclaimAgedImpl, AggSvcGroupByRefcountedNoAccessImpl, AggSvcGroupByRefcountedWAccessImpl, AggSvcGroupByRefcountedWAccessRollupImpl

public abstract class AggregationServiceBaseGrouped
extends java.lang.Object
implements AggregationService

All aggregation services require evaluation nodes which supply the value to be aggregated (summed, averaged, etc.) and aggregation state factories to make new aggregation states.

Field Summary

protected AggregationMethodFactory[]	aggregators Aggregation states and factories.
protected ExprEvaluator[]	evaluators Evaluation nodes under.
protected java.lang.Object	groupKeyBinding

Constructor Summary

AggregationServiceBaseGrouped(ExprEvaluator[] evaluators, AggregationMethodFactory[] aggregators, java.lang.Object groupKeyBinding)
Ctor.

Method Summary

void	stop() Stops the underlying resources.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.espertech.esper.epl.agg.service.AggregationService

accept, acceptGroupDetail, applyEnter, applyLeave, clearResults, isGrouped, setCurrentAccess, setRemovedCallback

Methods inherited from interface com.espertech.esper.epl.agg.service.AggregationResultFuture

getCollectionOfEvents, getCollectionScalar, getEventBean, getGroupKey, getGroupKeys, getValue

Field Detail

evaluators

protected ExprEvaluator[] evaluators

Evaluation nodes under.

aggregators

protected AggregationMethodFactory[] aggregators

Aggregation states and factories.

groupKeyBinding

protected java.lang.Object groupKeyBinding

Constructor Detail

AggregationServiceBaseGrouped

public AggregationServiceBaseGrouped(ExprEvaluator[] evaluators,
                                     AggregationMethodFactory[] aggregators,
                                     java.lang.Object groupKeyBinding)

Ctor.

Parameters:

evaluators - - are the child node of each aggregation function used for computing the value to be aggregated

aggregators - - aggregation states/factories

Method Detail

stop

public void stop()

Description copied from interface: StopCallback

Stops the underlying resources.

Specified by:

stop in interface StopCallback