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

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

All Implemented Interfaces:

AggregationServiceFactory

public class AggSvcGroupByMixedAccessFactory
extends AggregationServiceFactoryBase

Implementation for handling aggregation with grouping by group-keys.

Field Summary

protected AggregationStateFactory[]	accessAggregations
protected AggregationAccessorSlotPair[]	accessors
protected boolean	isJoin

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

aggregators, evaluators, groupKeyBinding

Constructor Summary

AggSvcGroupByMixedAccessFactory(ExprEvaluator[] evaluators, AggregationMethodFactory[] prototypes, java.lang.Object groupKeyBinding, AggregationAccessorSlotPair[] accessors, AggregationStateFactory[] accessAggregations, boolean isJoin)
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

Constructor Detail

AggSvcGroupByMixedAccessFactory

public AggSvcGroupByMixedAccessFactory(ExprEvaluator[] evaluators,
                                       AggregationMethodFactory[] prototypes,
                                       java.lang.Object groupKeyBinding,
                                       AggregationAccessorSlotPair[] accessors,
                                       AggregationStateFactory[] accessAggregations,
                                       boolean isJoin)

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

Method Detail

makeService

public AggregationService makeService(AgentInstanceContext agentInstanceContext,
                                      MethodResolutionService methodResolutionService)