com.espertech.esper.epl.agg.service

Class AggSvcGroupByRefcountedWAccessRollupFactory

java.lang.Object

com.espertech.esper.epl.agg.service.AggregationServiceFactoryBase

com.espertech.esper.epl.agg.service.AggSvcGroupByRefcountedWAccessRollupFactory

All Implemented Interfaces:

AggregationServiceFactory

public class AggSvcGroupByRefcountedWAccessRollupFactory
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 AggregationGroupByRollupDesc	groupByRollupDesc
protected boolean	isJoin

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

aggregators, evaluators

Constructor Summary

Constructors

Constructor and Description
AggSvcGroupByRefcountedWAccessRollupFactory(ExprEvaluator[] evaluators, AggregationMethodFactory[] prototypes, AggregationAccessorSlotPair[] accessors, AggregationStateFactory[] accessAggregations, boolean isJoin, AggregationGroupByRollupDesc groupByRollupDesc) 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

groupByRollupDesc

protected final AggregationGroupByRollupDesc groupByRollupDesc

Constructor Detail

AggSvcGroupByRefcountedWAccessRollupFactory

public AggSvcGroupByRefcountedWAccessRollupFactory(ExprEvaluator[] evaluators,
                                                   AggregationMethodFactory[] prototypes,
                                                   AggregationAccessorSlotPair[] accessors,
                                                   AggregationStateFactory[] accessAggregations,
                                                   boolean isJoin,
                                                   AggregationGroupByRollupDesc groupByRollupDesc)

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

accessors - accessor definitions

accessAggregations - access aggs

isJoin - true for join, false for single-stream

groupByRollupDesc - rollups if any

Method Detail

makeService

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