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

java.lang.Object
  com.espertech.esper.epl.agg.service.AggregationServiceFactoryBase
      com.espertech.esper.epl.agg.service.AggSvcGroupByReclaimAgedFactory

All Implemented Interfaces:

AggregationServiceFactory

public class AggSvcGroupByReclaimAgedFactory
extends AggregationServiceFactoryBase

Implementation for handling aggregation with grouping by group-keys.

Field Summary

protected AggregationStateFactory[]	accessAggregations
protected AggregationAccessorSlotPair[]	accessors
protected AggSvcGroupByReclaimAgedEvalFuncFactory	evaluationFunctionFrequency
protected AggSvcGroupByReclaimAgedEvalFuncFactory	evaluationFunctionMaxAge
protected boolean	isJoin

Fields inherited from class com.espertech.esper.epl.agg.service.AggregationServiceFactoryBase

aggregators, evaluators, groupKeyBinding

Constructor Summary

AggSvcGroupByReclaimAgedFactory(ExprEvaluator[] evaluators, AggregationMethodFactory[] prototypes, java.lang.Object groupKeyBinding, Hint reclaimGroupAged, Hint reclaimGroupFrequency, VariableService variableService, AggregationAccessorSlotPair[] accessors, AggregationStateFactory[] accessAggregations, boolean isJoin, java.lang.String optionalContextName)
Ctor.

Method Summary

AggregationService

makeService(AgentInstanceContext agentInstanceContext, MethodResolutionService methodResolutionService)

Methods inherited from class java.lang.Object

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

Field Detail

accessors

protected final AggregationAccessorSlotPair[] accessors

accessAggregations

protected final AggregationStateFactory[] accessAggregations

isJoin

protected final boolean isJoin

evaluationFunctionMaxAge

protected final AggSvcGroupByReclaimAgedEvalFuncFactory evaluationFunctionMaxAge

evaluationFunctionFrequency

protected final AggSvcGroupByReclaimAgedEvalFuncFactory evaluationFunctionFrequency

Constructor Detail

AggSvcGroupByReclaimAgedFactory

public AggSvcGroupByReclaimAgedFactory(ExprEvaluator[] evaluators,
                                       AggregationMethodFactory[] prototypes,
                                       java.lang.Object groupKeyBinding,
                                       Hint reclaimGroupAged,
                                       Hint reclaimGroupFrequency,
                                       VariableService variableService,
                                       AggregationAccessorSlotPair[] accessors,
                                       AggregationStateFactory[] accessAggregations,
                                       boolean isJoin,
                                       java.lang.String optionalContextName)
                                throws ExprValidationException

Ctor.

Parameters:

evaluators - - evaluate the sub-expression within the aggregate function (ie. sum(4*myNum))

prototypes - - collect the aggregation state that evaluators evaluate to, act as prototypes for new aggregations aggregation states for each group

reclaimGroupAged - hint to reclaim

reclaimGroupFrequency - hint to reclaim

variableService - variables

accessors - accessor definitions

accessAggregations - access aggs

isJoin - true for join, false for single-stream

Throws:

ExprValidationException - when validation fails

Method Detail

makeService

public AggregationService makeService(AgentInstanceContext agentInstanceContext,
                                      MethodResolutionService methodResolutionService)