com.espertech.esper.epl.agg.service

Class AggregationServiceBaseUngrouped

java.lang.Object

com.espertech.esper.epl.agg.service.AggregationServiceBaseUngrouped

All Implemented Interfaces:

AggregationResultFuture, AggregationService, StopCallback

Direct Known Subclasses:

AggSvcGroupAllMixedAccessImpl, AggSvcGroupAllNoAccessImpl

public abstract class AggregationServiceBaseUngrouped
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 AggregationStateFactory[]	accessAggregations
protected AggregationMethodFactory[]	aggregatorFactories
protected AggregationMethod[]	aggregators Aggregation states.
protected ExprEvaluator[]	evaluators Evaluation nodes under.

Constructor Summary

Constructors

Constructor and Description
AggregationServiceBaseUngrouped(ExprEvaluator[] evaluators, AggregationMethod[] aggregators, AggregationMethodFactory[] aggregatorFactories, AggregationStateFactory[] accessAggregations) Ctor.

Method Summary

Modifier and Type	Method and Description
AggregationService	getContextPartitionAggregationService(int agentInstanceId)
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 AggregationMethod[] aggregators

Aggregation states.

aggregatorFactories

protected AggregationMethodFactory[] aggregatorFactories

accessAggregations

protected AggregationStateFactory[] accessAggregations

Constructor Detail

AggregationServiceBaseUngrouped

public AggregationServiceBaseUngrouped(ExprEvaluator[] evaluators,
                                       AggregationMethod[] aggregators,
                                       AggregationMethodFactory[] aggregatorFactories,
                                       AggregationStateFactory[] accessAggregations)

Ctor.

Parameters:

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

aggregators - - aggregation states/factories

aggregatorFactories - method factories

accessAggregations - access aggs

Method Detail

stop

public void stop()

Description copied from interface: StopCallback

Stops the underlying resources.

Specified by:

stop in interface StopCallback

getContextPartitionAggregationService

public AggregationService getContextPartitionAggregationService(int agentInstanceId)

Specified by:

getContextPartitionAggregationService in interface AggregationService