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

Fields

Modifier and Type	Field and Description
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

Constructor Summary

Constructors

Constructor and Description
AggSvcGroupByReclaimAgedFactory(ExprEvaluator[] evaluators, AggregationMethodFactory[] prototypes, Hint reclaimGroupAged, Hint reclaimGroupFrequency, VariableService variableService, AggregationAccessorSlotPair[] accessors, AggregationStateFactory[] accessAggregations, boolean isJoin, String optionalContextName) Ctor.

Method Summary

Modifier and Type	Method and Description
AggregationService	makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)

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,
                                       Hint reclaimGroupAged,
                                       Hint reclaimGroupFrequency,
                                       VariableService variableService,
                                       AggregationAccessorSlotPair[] accessors,
                                       AggregationStateFactory[] accessAggregations,
                                       boolean isJoin,
                                       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

optionalContextName - context name

Throws:

ExprValidationException - when validation fails

Method Detail

makeService

public AggregationService makeService(AgentInstanceContext agentInstanceContext,
                                      EngineImportService engineImportService,
                                      boolean isSubquery,
                                      Integer subqueryNumber)