com.espertech.esper.epl.agg.service.groupbyrollup

Class AggSvcGroupByRollupFactory

java.lang.Object

com.espertech.esper.epl.agg.service.groupbyrollup.AggSvcGroupByRollupFactory

All Implemented Interfaces:

AggregationServiceFactory

public class AggSvcGroupByRollupFactory
extends java.lang.Object
implements AggregationServiceFactory

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 AggregationMethodFactory[]	aggregators
protected ExprEvaluator[]	evaluators
protected AggregationGroupByRollupDesc	groupByRollupDesc
protected boolean	isJoin

Constructor Summary

Constructors

Constructor and Description
AggSvcGroupByRollupFactory(AggregationRowStateEvalDesc eval, boolean isJoin, AggregationGroupByRollupDesc groupByRollupDesc)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

evaluators

protected final ExprEvaluator[] evaluators

aggregators

protected final AggregationMethodFactory[] aggregators

accessors

protected final AggregationAccessorSlotPair[] accessors

accessAggregations

protected final AggregationStateFactory[] accessAggregations

isJoin

protected final boolean isJoin

groupByRollupDesc

protected final AggregationGroupByRollupDesc groupByRollupDesc

Constructor Detail

AggSvcGroupByRollupFactory

public AggSvcGroupByRollupFactory(AggregationRowStateEvalDesc eval,
                                  boolean isJoin,
                                  AggregationGroupByRollupDesc groupByRollupDesc)

Method Detail

makeService

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

Specified by:

makeService in interface AggregationServiceFactory