com.espertech.esper.epl.agg.service

Class AggregationServiceBase

java.lang.Object

com.espertech.esper.epl.agg.service.AggregationServiceBase

All Implemented Interfaces:

AggregationResultFuture, AggregationService, StopCallback

public abstract class AggregationServiceBase
extends 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

Fields

Modifier and Type	Field and Description
protected ExprEvaluator[]	evaluators Evaluation nodes under.

Constructor Summary

Constructors

Constructor and Description
AggregationServiceBase(ExprEvaluator[] evaluators) Ctor.

Method Summary

Modifier and Type	Method and Description
ExprEvaluator[]	getEvaluators()

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

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

getCollectionOfEvents, getCollectionScalar, getEventBean, getGroupKey, getGroupKeys, getValue

Methods inherited from interface com.espertech.esper.util.StopCallback

stop

Field Detail

evaluators

protected ExprEvaluator[] evaluators

Evaluation nodes under.

Constructor Detail

AggregationServiceBase

public AggregationServiceBase(ExprEvaluator[] evaluators)

Ctor.

Parameters:

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

Method Detail

getEvaluators

public ExprEvaluator[] getEvaluators()