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

Class AggregationServiceFactoryFactory

java.lang.Object

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

public class AggregationServiceFactoryFactory
extends java.lang.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 AggregationServiceForgeDesc	getService(java.util.List<ExprAggregateNode> selectAggregateExprNodes, java.util.Map<ExprNode,java.lang.String> selectClauseNamedNodes, java.util.List<ExprDeclaredNode> declaredExpressions, ExprNode[] groupByNodes, java.util.List<ExprAggregateNode> havingAggregateExprNodes, java.util.List<ExprAggregateNode> orderByAggregateExprNodes, java.util.List<ExprAggregateNodeGroupKey> groupKeyExpressions, boolean hasGroupByClause, java.lang.annotation.Annotation[] annotations, VariableService variableService, boolean isJoin, boolean isDisallowNoReclaim, ExprNode whereClause, ExprNode havingClause, AggregationServiceFactoryService factoryService, EventType[] typesPerStream, AggregationGroupByRollupDesc groupByRollupDesc, java.lang.String optionalContextName, IntoTableSpec intoTableSpec, TableService tableService, boolean isUnidirectional, boolean isFireAndForget, boolean isOnSelect, EngineImportService engineImportService, java.lang.String statementName, TimeAbacus timeAbacus)
static AggregationServiceMatchRecognizeFactoryDesc	getServiceMatchRecognize(int numStreams, java.util.Map<java.lang.Integer,java.util.List<ExprAggregateNode>> measureExprNodesPerStream, EventType[] typesPerStream, EngineImportService engineImportService, java.lang.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,
                                                                                   java.util.Map<java.lang.Integer,java.util.List<ExprAggregateNode>> measureExprNodesPerStream,
                                                                                   EventType[] typesPerStream,
                                                                                   EngineImportService engineImportService,
                                                                                   java.lang.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 AggregationServiceForgeDesc getService(java.util.List<ExprAggregateNode> selectAggregateExprNodes,
                                                     java.util.Map<ExprNode,java.lang.String> selectClauseNamedNodes,
                                                     java.util.List<ExprDeclaredNode> declaredExpressions,
                                                     ExprNode[] groupByNodes,
                                                     java.util.List<ExprAggregateNode> havingAggregateExprNodes,
                                                     java.util.List<ExprAggregateNode> orderByAggregateExprNodes,
                                                     java.util.List<ExprAggregateNodeGroupKey> groupKeyExpressions,
                                                     boolean hasGroupByClause,
                                                     java.lang.annotation.Annotation[] annotations,
                                                     VariableService variableService,
                                                     boolean isJoin,
                                                     boolean isDisallowNoReclaim,
                                                     ExprNode whereClause,
                                                     ExprNode havingClause,
                                                     AggregationServiceFactoryService factoryService,
                                                     EventType[] typesPerStream,
                                                     AggregationGroupByRollupDesc groupByRollupDesc,
                                                     java.lang.String optionalContextName,
                                                     IntoTableSpec intoTableSpec,
                                                     TableService tableService,
                                                     boolean isUnidirectional,
                                                     boolean isFireAndForget,
                                                     boolean isOnSelect,
                                                     EngineImportService engineImportService,
                                                     java.lang.String statementName,
                                                     TimeAbacus timeAbacus)
                                              throws ExprValidationException

Throws:

ExprValidationException

getRollupReclaimEx

public static ExprValidationException getRollupReclaimEx()