com.espertech.esper.epl.agg.service

Class AggregationServiceFactoryServiceImpl

java.lang.Object

com.espertech.esper.epl.agg.service.AggregationServiceFactoryServiceImpl

All Implemented Interfaces:

AggregationServiceFactoryService

public class AggregationServiceFactoryServiceImpl
extends Object
implements AggregationServiceFactoryService

Field Summary

Fields

Modifier and Type	Field and Description
static AggregationServiceFactoryService	DEFAULT_FACTORY

Constructor Summary

Constructors

Constructor and Description
AggregationServiceFactoryServiceImpl()

Method Summary

Modifier and Type	Method and Description
AggregationServiceFactory	getGroupedNoReclaimNoAccess(ExprNode[] groupByNodes, ExprEvaluator[] evaluatorsArr, AggregationMethodFactory[] aggregatorsArr, boolean isUnidirectional, boolean isFireAndForget, boolean isOnSelect)
AggregationServiceFactory	getGroupLocalGroupBy(boolean join, AggregationLocalGroupByPlan localGroupByPlan, boolean isUnidirectional, boolean isFireAndForget, boolean isOnSelect)
AggregationServiceFactory	getGroupNoReclaimAccessOnly(ExprNode[] groupByNodes, AggregationAccessorSlotPair[] pairs, AggregationStateFactory[] accessAggSpecs, boolean join, boolean isUnidirectional, boolean isFireAndForget, boolean isOnSelect)
AggregationServiceFactory	getGroupNoReclaimMixed(ExprNode[] groupByNodes, ExprEvaluator[] evaluatorsArr, AggregationMethodFactory[] aggregatorsArr, AggregationAccessorSlotPair[] pairs, AggregationStateFactory[] accessAggregations, boolean join, boolean isUnidirectional, boolean isFireAndForget, boolean isOnSelect)
AggregationServiceFactory	getGroupReclaimAged(ExprNode[] groupByNodes, ExprEvaluator[] evaluatorsArr, AggregationMethodFactory[] aggregatorsArr, Hint reclaimGroupAged, Hint reclaimGroupFrequency, VariableService variableService, AggregationAccessorSlotPair[] pairs, AggregationStateFactory[] accessAggregations, boolean join, String optionalContextName, boolean isUnidirectional, boolean isFireAndForget, boolean isOnSelect)
AggregationServiceFactory	getGroupReclaimMixable(ExprNode[] groupByNodes, ExprEvaluator[] evaluatorsArr, AggregationMethodFactory[] aggregatorsArr, AggregationAccessorSlotPair[] pairs, AggregationStateFactory[] accessAggregations, boolean join, boolean isUnidirectional, boolean isFireAndForget, boolean isOnSelect)
AggregationServiceFactory	getGroupReclaimMixableRollup(ExprNode[] groupByNodes, AggregationGroupByRollupDesc byRollupDesc, ExprEvaluator[] evaluatorsArr, AggregationMethodFactory[] aggregatorsArr, AggregationAccessorSlotPair[] pairs, AggregationStateFactory[] accessAggregations, boolean join, AggregationGroupByRollupDesc groupByRollupDesc, boolean isUnidirectional, boolean isFireAndForget, boolean isOnSelect)
AggregationServiceFactory	getGroupReclaimNoAccess(ExprNode[] groupByNodes, ExprEvaluator[] evaluatorsArr, AggregationMethodFactory[] aggregatorsArr, AggregationAccessorSlotPair[] pairs, AggregationStateFactory[] accessAggregations, boolean join, boolean isUnidirectional, boolean isFireAndForget, boolean isOnSelect)
AggregationServiceFactory	getGroupWBinding(TableMetadata tableMetadata, TableColumnMethodPair[] methodPairs, AggregationAccessorSlotPair[] accessorPairs, boolean join, IntoTableSpec bindings, int[] targetStates, ExprNode[] accessStateExpr, AggregationAgent[] agents, AggregationGroupByRollupDesc groupByRollupDesc)
AggregationServiceFactory	getNoGroupAccessMixed(ExprEvaluator[] evaluatorsArr, AggregationMethodFactory[] aggregatorsArr, AggregationAccessorSlotPair[] pairs, AggregationStateFactory[] accessAggregations, boolean join, boolean isUnidirectional, boolean isFireAndForget, boolean isOnSelect)
AggregationServiceFactory	getNoGroupAccessOnly(AggregationAccessorSlotPair[] pairs, AggregationStateFactory[] accessAggSpecs, boolean join, boolean isUnidirectional, boolean isFireAndForget, boolean isOnSelect)
AggregationServiceFactory	getNoGroupLocalGroupBy(boolean join, AggregationLocalGroupByPlan localGroupByPlan, boolean isUnidirectional, boolean isFireAndForget, boolean isOnSelect)
AggregationServiceFactory	getNoGroupNoAccess(ExprEvaluator[] evaluatorsArr, AggregationMethodFactory[] aggregatorsArr, boolean isUnidirectional, boolean isFireAndForget, boolean isOnSelect)
AggregationServiceFactory	getNoGroupWBinding(AggregationAccessorSlotPair[] accessors, boolean join, TableColumnMethodPair[] methodPairs, String tableName, int[] targetStates, ExprNode[] accessStateExpr, AggregationAgent[] agents)
AggregationServiceFactory	getNullAggregationService()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_FACTORY

public static final AggregationServiceFactoryService DEFAULT_FACTORY

Constructor Detail

AggregationServiceFactoryServiceImpl

public AggregationServiceFactoryServiceImpl()

Method Detail

getNullAggregationService

public AggregationServiceFactory getNullAggregationService()

Specified by:

getNullAggregationService in interface AggregationServiceFactoryService

getNoGroupNoAccess

public AggregationServiceFactory getNoGroupNoAccess(ExprEvaluator[] evaluatorsArr,
                                                    AggregationMethodFactory[] aggregatorsArr,
                                                    boolean isUnidirectional,
                                                    boolean isFireAndForget,
                                                    boolean isOnSelect)

Specified by:

getNoGroupNoAccess in interface AggregationServiceFactoryService

getNoGroupAccessOnly

public AggregationServiceFactory getNoGroupAccessOnly(AggregationAccessorSlotPair[] pairs,
                                                      AggregationStateFactory[] accessAggSpecs,
                                                      boolean join,
                                                      boolean isUnidirectional,
                                                      boolean isFireAndForget,
                                                      boolean isOnSelect)

Specified by:

getNoGroupAccessOnly in interface AggregationServiceFactoryService

getNoGroupAccessMixed

public AggregationServiceFactory getNoGroupAccessMixed(ExprEvaluator[] evaluatorsArr,
                                                       AggregationMethodFactory[] aggregatorsArr,
                                                       AggregationAccessorSlotPair[] pairs,
                                                       AggregationStateFactory[] accessAggregations,
                                                       boolean join,
                                                       boolean isUnidirectional,
                                                       boolean isFireAndForget,
                                                       boolean isOnSelect)

Specified by:

getNoGroupAccessMixed in interface AggregationServiceFactoryService

getGroupedNoReclaimNoAccess

public AggregationServiceFactory getGroupedNoReclaimNoAccess(ExprNode[] groupByNodes,
                                                             ExprEvaluator[] evaluatorsArr,
                                                             AggregationMethodFactory[] aggregatorsArr,
                                                             boolean isUnidirectional,
                                                             boolean isFireAndForget,
                                                             boolean isOnSelect)

Specified by:

getGroupedNoReclaimNoAccess in interface AggregationServiceFactoryService

getGroupNoReclaimAccessOnly

public AggregationServiceFactory getGroupNoReclaimAccessOnly(ExprNode[] groupByNodes,
                                                             AggregationAccessorSlotPair[] pairs,
                                                             AggregationStateFactory[] accessAggSpecs,
                                                             boolean join,
                                                             boolean isUnidirectional,
                                                             boolean isFireAndForget,
                                                             boolean isOnSelect)

Specified by:

getGroupNoReclaimAccessOnly in interface AggregationServiceFactoryService

getGroupNoReclaimMixed

public AggregationServiceFactory getGroupNoReclaimMixed(ExprNode[] groupByNodes,
                                                        ExprEvaluator[] evaluatorsArr,
                                                        AggregationMethodFactory[] aggregatorsArr,
                                                        AggregationAccessorSlotPair[] pairs,
                                                        AggregationStateFactory[] accessAggregations,
                                                        boolean join,
                                                        boolean isUnidirectional,
                                                        boolean isFireAndForget,
                                                        boolean isOnSelect)

Specified by:

getGroupNoReclaimMixed in interface AggregationServiceFactoryService

getGroupReclaimAged

public AggregationServiceFactory getGroupReclaimAged(ExprNode[] groupByNodes,
                                                     ExprEvaluator[] evaluatorsArr,
                                                     AggregationMethodFactory[] aggregatorsArr,
                                                     Hint reclaimGroupAged,
                                                     Hint reclaimGroupFrequency,
                                                     VariableService variableService,
                                                     AggregationAccessorSlotPair[] pairs,
                                                     AggregationStateFactory[] accessAggregations,
                                                     boolean join,
                                                     String optionalContextName,
                                                     boolean isUnidirectional,
                                                     boolean isFireAndForget,
                                                     boolean isOnSelect)
                                              throws ExprValidationException

Specified by:

getGroupReclaimAged in interface AggregationServiceFactoryService

Throws:

ExprValidationException

getGroupReclaimNoAccess

public AggregationServiceFactory getGroupReclaimNoAccess(ExprNode[] groupByNodes,
                                                         ExprEvaluator[] evaluatorsArr,
                                                         AggregationMethodFactory[] aggregatorsArr,
                                                         AggregationAccessorSlotPair[] pairs,
                                                         AggregationStateFactory[] accessAggregations,
                                                         boolean join,
                                                         boolean isUnidirectional,
                                                         boolean isFireAndForget,
                                                         boolean isOnSelect)

Specified by:

getGroupReclaimNoAccess in interface AggregationServiceFactoryService

getGroupReclaimMixable

public AggregationServiceFactory getGroupReclaimMixable(ExprNode[] groupByNodes,
                                                        ExprEvaluator[] evaluatorsArr,
                                                        AggregationMethodFactory[] aggregatorsArr,
                                                        AggregationAccessorSlotPair[] pairs,
                                                        AggregationStateFactory[] accessAggregations,
                                                        boolean join,
                                                        boolean isUnidirectional,
                                                        boolean isFireAndForget,
                                                        boolean isOnSelect)

Specified by:

getGroupReclaimMixable in interface AggregationServiceFactoryService

getGroupReclaimMixableRollup

public AggregationServiceFactory getGroupReclaimMixableRollup(ExprNode[] groupByNodes,
                                                              AggregationGroupByRollupDesc byRollupDesc,
                                                              ExprEvaluator[] evaluatorsArr,
                                                              AggregationMethodFactory[] aggregatorsArr,
                                                              AggregationAccessorSlotPair[] pairs,
                                                              AggregationStateFactory[] accessAggregations,
                                                              boolean join,
                                                              AggregationGroupByRollupDesc groupByRollupDesc,
                                                              boolean isUnidirectional,
                                                              boolean isFireAndForget,
                                                              boolean isOnSelect)

Specified by:

getGroupReclaimMixableRollup in interface AggregationServiceFactoryService

getGroupWBinding

public AggregationServiceFactory getGroupWBinding(TableMetadata tableMetadata,
                                                  TableColumnMethodPair[] methodPairs,
                                                  AggregationAccessorSlotPair[] accessorPairs,
                                                  boolean join,
                                                  IntoTableSpec bindings,
                                                  int[] targetStates,
                                                  ExprNode[] accessStateExpr,
                                                  AggregationAgent[] agents,
                                                  AggregationGroupByRollupDesc groupByRollupDesc)

Specified by:

getGroupWBinding in interface AggregationServiceFactoryService

getNoGroupWBinding

public AggregationServiceFactory getNoGroupWBinding(AggregationAccessorSlotPair[] accessors,
                                                    boolean join,
                                                    TableColumnMethodPair[] methodPairs,
                                                    String tableName,
                                                    int[] targetStates,
                                                    ExprNode[] accessStateExpr,
                                                    AggregationAgent[] agents)

Specified by:

getNoGroupWBinding in interface AggregationServiceFactoryService

getNoGroupLocalGroupBy

public AggregationServiceFactory getNoGroupLocalGroupBy(boolean join,
                                                        AggregationLocalGroupByPlan localGroupByPlan,
                                                        boolean isUnidirectional,
                                                        boolean isFireAndForget,
                                                        boolean isOnSelect)

Specified by:

getNoGroupLocalGroupBy in interface AggregationServiceFactoryService

getGroupLocalGroupBy

public AggregationServiceFactory getGroupLocalGroupBy(boolean join,
                                                      AggregationLocalGroupByPlan localGroupByPlan,
                                                      boolean isUnidirectional,
                                                      boolean isFireAndForget,
                                                      boolean isOnSelect)

Specified by:

getGroupLocalGroupBy in interface AggregationServiceFactoryService