com.espertech.esper.epl.agg.service

Class AggregationServiceFactoryFactory

java.lang.Object

com.espertech.esper.epl.agg.service.AggregationServiceFactoryFactory

public class AggregationServiceFactoryFactory
extends Object

Factory for aggregation service instances.

Consolidates aggregation nodes such that result futures point to a single instance and no re-evaluation of the same result occurs.

Constructor Summary

Constructors

Constructor and Description
AggregationServiceFactoryFactory()

Method Summary

Modifier and Type	Method and Description
static ExprValidationException	getRollupReclaimEx()
static AggregationServiceFactoryDesc	getService(List<ExprAggregateNode> selectAggregateExprNodes, Map<ExprNode,String> selectClauseNamedNodes, List<ExprDeclaredNode> declaredExpressions, ExprNode[] groupByNodes, List<ExprAggregateNode> havingAggregateExprNodes, List<ExprAggregateNode> orderByAggregateExprNodes, List<ExprAggregateNodeGroupKey> groupKeyExpressions, boolean hasGroupByClause, Annotation[] annotations, VariableService variableService, boolean isJoin, boolean isDisallowNoReclaim, ExprNode whereClause, ExprNode havingClause, AggregationServiceFactoryService factoryService, EventType[] typesPerStream, AggregationGroupByRollupDesc groupByRollupDesc, String optionalContextName, IntoTableSpec intoTableSpec, TableService tableService, boolean isUnidirectional, boolean isFireAndForget, boolean isOnSelect, EngineImportService engineImportService, String statementName)
static AggregationServiceMatchRecognizeFactoryDesc	getServiceMatchRecognize(int numStreams, Map<Integer,List<ExprAggregateNode>> measureExprNodesPerStream, EventType[] typesPerStream, EngineImportService engineImportService, String statementName) Produces an aggregation service for use with match-recognice.

Methods inherited from class java.lang.Object

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

Constructor Detail

AggregationServiceFactoryFactory

public AggregationServiceFactoryFactory()

Method Detail

getServiceMatchRecognize

public static AggregationServiceMatchRecognizeFactoryDesc getServiceMatchRecognize(int numStreams,
                                                                                   Map<Integer,List<ExprAggregateNode>> measureExprNodesPerStream,
                                                                                   EventType[] typesPerStream,
                                                                                   EngineImportService engineImportService,
                                                                                   String statementName)
                                                                            throws ExprValidationException

Produces an aggregation service for use with match-recognice.

Parameters:

numStreams - number of streams

measureExprNodesPerStream - measure nodes

typesPerStream - type information

statementName - statement name

engineImportService - engine imports

Returns:

service

Throws:

ExprValidationException - for validation errors

getService

public static AggregationServiceFactoryDesc getService(List<ExprAggregateNode> selectAggregateExprNodes,
                                                       Map<ExprNode,String> selectClauseNamedNodes,
                                                       List<ExprDeclaredNode> declaredExpressions,
                                                       ExprNode[] groupByNodes,
                                                       List<ExprAggregateNode> havingAggregateExprNodes,
                                                       List<ExprAggregateNode> orderByAggregateExprNodes,
                                                       List<ExprAggregateNodeGroupKey> groupKeyExpressions,
                                                       boolean hasGroupByClause,
                                                       Annotation[] annotations,
                                                       VariableService variableService,
                                                       boolean isJoin,
                                                       boolean isDisallowNoReclaim,
                                                       ExprNode whereClause,
                                                       ExprNode havingClause,
                                                       AggregationServiceFactoryService factoryService,
                                                       EventType[] typesPerStream,
                                                       AggregationGroupByRollupDesc groupByRollupDesc,
                                                       String optionalContextName,
                                                       IntoTableSpec intoTableSpec,
                                                       TableService tableService,
                                                       boolean isUnidirectional,
                                                       boolean isFireAndForget,
                                                       boolean isOnSelect,
                                                       EngineImportService engineImportService,
                                                       String statementName)
                                                throws ExprValidationException

Throws:

ExprValidationException

getRollupReclaimEx

public static ExprValidationException getRollupReclaimEx()