com.espertech.esper.epl.agg.service.common

Class AggregationServiceFactoryServiceImpl

java.lang.Object

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

All Implemented Interfaces:

AggregationServiceFactoryService

public class AggregationServiceFactoryServiceImpl
extends java.lang.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
AggregationServiceFactoryForge	getGroupBy(AggGroupByDesc aggGroupByDesc, TimeAbacus timeAbacus, boolean isUnidirectional, boolean isFireAndForget, boolean isOnSelect)
AggregationServiceFactoryForge	getGroupLocalGroupBy(boolean hasGroupByClause, boolean join, AggregationLocalGroupByPlanForge localGroupByPlan, boolean isUnidirectional, boolean isFireAndForget, boolean isOnSelect)
AggregationServiceFactoryForge	getNoGroup(AggregationRowStateForgeDesc rowStateDesc, boolean join, boolean isUnidirectional, boolean isFireAndForget, boolean isOnSelect)
AggregationServiceFactoryForge	getNullAggregationService()
AggregationServiceFactoryForge	getRollup(ExprNode[] groupByNodes, AggregationGroupByRollupDesc rollupDesc, AggregationRowStateForgeDesc rowStateDesc, boolean join, AggregationGroupByRollupDesc groupByRollupDesc, boolean isUnidirectional, boolean isFireAndForget, boolean isOnSelect)
AggregationServiceFactoryForge	getTable(TableService tableService, TableMetadata tableMetadata, TableColumnMethodPair[] methodPairs, AggregationAccessorSlotPairForge[] accessorPairs, AggregationAccessorSlotPair[] accessors, boolean join, int[] targetStates, ExprNode[] accessStateExpr, AggregationAgentForge[] agentForges, AggregationAgent[] agents, AggregationGroupByRollupDesc groupByRollupDesc, boolean hasGroupBy)

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 AggregationServiceFactoryForge getNullAggregationService()

Specified by:

getNullAggregationService in interface AggregationServiceFactoryService

getNoGroup

public AggregationServiceFactoryForge getNoGroup(AggregationRowStateForgeDesc rowStateDesc,
                                                 boolean join,
                                                 boolean isUnidirectional,
                                                 boolean isFireAndForget,
                                                 boolean isOnSelect)

Specified by:

getNoGroup in interface AggregationServiceFactoryService

getGroupBy

public AggregationServiceFactoryForge getGroupBy(AggGroupByDesc aggGroupByDesc,
                                                 TimeAbacus timeAbacus,
                                                 boolean isUnidirectional,
                                                 boolean isFireAndForget,
                                                 boolean isOnSelect)

Specified by:

getGroupBy in interface AggregationServiceFactoryService

getGroupLocalGroupBy

public AggregationServiceFactoryForge getGroupLocalGroupBy(boolean hasGroupByClause,
                                                           boolean join,
                                                           AggregationLocalGroupByPlanForge localGroupByPlan,
                                                           boolean isUnidirectional,
                                                           boolean isFireAndForget,
                                                           boolean isOnSelect)

Specified by:

getGroupLocalGroupBy in interface AggregationServiceFactoryService

getRollup

public AggregationServiceFactoryForge getRollup(ExprNode[] groupByNodes,
                                                AggregationGroupByRollupDesc rollupDesc,
                                                AggregationRowStateForgeDesc rowStateDesc,
                                                boolean join,
                                                AggregationGroupByRollupDesc groupByRollupDesc,
                                                boolean isUnidirectional,
                                                boolean isFireAndForget,
                                                boolean isOnSelect)

Specified by:

getRollup in interface AggregationServiceFactoryService

getTable

public AggregationServiceFactoryForge getTable(TableService tableService,
                                               TableMetadata tableMetadata,
                                               TableColumnMethodPair[] methodPairs,
                                               AggregationAccessorSlotPairForge[] accessorPairs,
                                               AggregationAccessorSlotPair[] accessors,
                                               boolean join,
                                               int[] targetStates,
                                               ExprNode[] accessStateExpr,
                                               AggregationAgentForge[] agentForges,
                                               AggregationAgent[] agents,
                                               AggregationGroupByRollupDesc groupByRollupDesc,
                                               boolean hasGroupBy)

Specified by:

getTable in interface AggregationServiceFactoryService