net.esper.eql.core
Class AggregationServiceBase

java.lang.Object
  extended by net.esper.eql.core.AggregationServiceBase
All Implemented Interfaces:
AggregationResultFuture, AggregationService
Direct Known Subclasses:
AggregationServiceGroupAllImpl, AggregationServiceGroupByImpl

public abstract class AggregationServiceBase
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  Aggregator[] aggregators
          Aggregation states and factories.
protected  ExprEvaluator[] evaluators
          Evaluation nodes under.
 
Constructor Summary
AggregationServiceBase(ExprEvaluator[] evaluators, Aggregator[] aggregators)
          Ctor.
 
Method Summary
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface net.esper.eql.core.AggregationService
applyEnter, applyLeave, setCurrentRow
 
Methods inherited from interface net.esper.eql.core.AggregationResultFuture
getValue
 

Field Detail

evaluators

protected ExprEvaluator[] evaluators
Evaluation nodes under.


aggregators

protected Aggregator[] aggregators
Aggregation states and factories.

Constructor Detail

AggregationServiceBase

public AggregationServiceBase(ExprEvaluator[] evaluators,
                              Aggregator[] aggregators)
Ctor.

Parameters:
evaluators - - are the child node of each aggregation function used for computing the value to be aggregated
aggregators - - aggregation states/factories