Uses of Interface
com.espertech.esper.epl.agg.service.AggregationService

Packages that use AggregationService

com.espertech.esper.core.context.factory	Statement agent instance factories.
com.espertech.esper.core.context.stmt	Registries for context partitions to handle aggregations, prev/prior and subselects.
com.espertech.esper.core.context.subselect	Subselect implementation.
com.espertech.esper.core.service.resource	Core service statement resource holders.
com.espertech.esper.core.start	Classes related to start and stop of statements
com.espertech.esper.epl.agg.service	Aggregation services.
com.espertech.esper.epl.core	Contains EPL statement specification classes define the constructs that make up an EPL statement, such as the list of items in the select clause, the insert-into stream name and property names etc.
com.espertech.esper.epl.expression.subquery	Subselect expressions.
com.espertech.esper.epl.subquery	Subquery helper classes are found here.
com.espertech.esper.view.window	Window views are in this package

Uses of AggregationService in com.espertech.esper.core.context.factory

Methods in com.espertech.esper.core.context.factory that return AggregationService

AggregationService	StatementAgentInstanceFactoryResult.getOptionalAggegationService()
AggregationService	StatementAgentInstanceFactoryOnTriggerBase.OnExprViewResult.getOptionalAggregationService()

Constructors in com.espertech.esper.core.context.factory with parameters of type AggregationService

StatementAgentInstanceFactoryOnTriggerBase.OnExprViewResult(View onExprView, AggregationService optionalAggregationService)

StatementAgentInstanceFactoryOnTriggerResult(Viewable finalView, StopCallback stopCallback, AgentInstanceContext agentInstanceContext, AggregationService aggregationService, java.util.Map<ExprSubselectNode,SubSelectStrategyHolder> subselectStrategies, EvalRootState optPatternRoot, java.util.Map<ExprTableAccessNode,ExprTableAccessEvalStrategy> tableAccessStrategies)

StatementAgentInstanceFactoryResult(Viewable finalView, StopCallback stopCallback, AgentInstanceContext agentInstanceContext, AggregationService optionalAggegationService, java.util.Map<ExprSubselectNode,SubSelectStrategyHolder> subselectStrategies, java.util.Map<ExprPriorNode,ExprPriorEvalStrategy> priorNodeStrategies, java.util.Map<ExprPreviousNode,ExprPreviousEvalStrategy> previousNodeStrategies, RegexExprPreviousEvalStrategy regexExprPreviousEvalStrategy, java.util.Map<ExprTableAccessNode,ExprTableAccessEvalStrategy> tableAccessStrategies, java.util.List<StatementAgentInstancePreload> preloadList)

StatementAgentInstanceFactorySelectResult(Viewable finalView, StopCallback stopCallback, AgentInstanceContext agentInstanceContext, AggregationService optionalAggegationService, java.util.Map<ExprSubselectNode,SubSelectStrategyHolder> subselectStrategies, java.util.Map<ExprPriorNode,ExprPriorEvalStrategy> priorNodeStrategies, java.util.Map<ExprPreviousNode,ExprPreviousEvalStrategy> previousNodeStrategies, RegexExprPreviousEvalStrategy regexExprPreviousEvalStrategy, java.util.Map<ExprTableAccessNode,ExprTableAccessEvalStrategy> tableAccessStrategies, java.util.List<StatementAgentInstancePreload> preloadList, EvalRootState[] patternRoots, StatementAgentInstancePostLoad optionalPostLoadJoin, Viewable[] topViews, Viewable[] eventStreamViewables)

Uses of AggregationService in com.espertech.esper.core.context.stmt

Subinterfaces of AggregationService in com.espertech.esper.core.context.stmt

interface

AIRegistryAggregation

Classes in com.espertech.esper.core.context.stmt that implement AggregationService

class	AIRegistryAggregationMap
class	AIRegistryAggregationMultiPerm
class	AIRegistryAggregationSingle

Methods in com.espertech.esper.core.context.stmt with parameters of type AggregationService

void	AIRegistryAggregationSingle.assignService(int serviceId, AggregationService aggregationService)
void	AIRegistryAggregationMultiPerm.assignService(int serviceId, AggregationService aggregationService)
void	AIRegistryAggregationMap.assignService(int serviceId, AggregationService aggregationService)
void	AIRegistryAggregation.assignService(int serviceId, AggregationService aggregationService)

Uses of AggregationService in com.espertech.esper.core.context.subselect

Methods in com.espertech.esper.core.context.subselect that return AggregationService

AggregationService	SubSelectStrategyRealization.getSubselectAggregationService()
AggregationService	SubSelectStrategyHolder.getSubselectAggregationService()

Constructors in com.espertech.esper.core.context.subselect with parameters of type AggregationService

SubSelectStrategyHolder(ExprSubselectStrategy stategy, AggregationService subselectAggregationService, java.util.Map<ExprPriorNode,ExprPriorEvalStrategy> priorStrategies, java.util.Map<ExprPreviousNode,ExprPreviousEvalStrategy> previousNodeStrategies, Viewable subselectView, StatementAgentInstancePostLoad postLoad)

SubSelectStrategyRealization(SubordTableLookupStrategy strategy, SubselectAggregationPreprocessorBase subselectAggregationPreprocessor, AggregationService subselectAggregationService, java.util.Map<ExprPriorNode,ExprPriorEvalStrategy> priorNodeStrategies, java.util.Map<ExprPreviousNode,ExprPreviousEvalStrategy> previousNodeStrategies, Viewable subselectView, StatementAgentInstancePostLoad postLoad)

Uses of AggregationService in com.espertech.esper.core.service.resource

Methods in com.espertech.esper.core.service.resource that return AggregationService

AggregationService

StatementResourceHolder.getAggegationService()

Constructors in com.espertech.esper.core.service.resource with parameters of type AggregationService

StatementResourceHolder(StatementAgentInstanceLock agentInstanceLock, Viewable[] topViewables, Viewable[] eventStreamViewables, EvalRootState[] patternRoots, AggregationService aggegationService, java.util.Map<ExprSubselectNode,SubSelectStrategyHolder> subselectStrategies, StatementAgentInstancePostLoad postLoad)

Uses of AggregationService in com.espertech.esper.core.start

Methods in com.espertech.esper.core.start that return types with arguments of type AggregationService

static Pair<ResultSetProcessor,AggregationService>

EPStatementStartMethodHelperUtil.startResultSetAndAggregation(ResultSetProcessorFactoryDesc resultSetProcessorPrototype, AgentInstanceContext agentInstanceContext)

Methods in com.espertech.esper.core.start with parameters of type AggregationService

static void

EPStatementStartMethodHelperAssignExpr.assignExpressionStrategies(EPStatementStartMethodSelectDesc selectDesc, AggregationService aggregationService, java.util.Map<ExprSubselectNode,SubSelectStrategyHolder> subselectStrategyInstances, java.util.Map<ExprPriorNode,ExprPriorEvalStrategy> priorStrategyInstances, java.util.Map<ExprPreviousNode,ExprPreviousEvalStrategy> previousStrategyInstances, java.util.Set<ExprPreviousMatchRecognizeNode> matchRecognizeNodes, RegexExprPreviousEvalStrategy matchRecognizePrevEvalStrategy, java.util.Map<ExprTableAccessNode,ExprTableAccessEvalStrategy> tableAccessStrategyInstances)

Uses of AggregationService in com.espertech.esper.epl.agg.service

Classes in com.espertech.esper.epl.agg.service that implement AggregationService

class	AggregationServiceBase All aggregation services require evaluation nodes which supply the value to be aggregated (summed, averaged, etc.) and aggregation state factories to make new aggregation states.
class	AggregationServiceBaseGrouped All aggregation services require evaluation nodes which supply the value to be aggregated (summed, averaged, etc.) and aggregation state factories to make new aggregation states.
class	AggregationServiceBaseUngrouped All aggregation services require evaluation nodes which supply the value to be aggregated (summed, averaged, etc.) and aggregation state factories to make new aggregation states.
class	AggregationServiceNull A null object implementation of the AggregationService interface.
class	AggregationServiceTable
class	AggSvcGroupAllAccessOnlyImpl Aggregation service for use when only first/last/window aggregation functions are used an none other.
class	AggSvcGroupAllLocalGroupBy Implementation for handling aggregation with grouping by group-keys.
class	AggSvcGroupAllMixedAccessImpl Implementation for handling aggregation without any grouping (no group-by).
class	AggSvcGroupAllMixedAccessWTableImpl Implementation for handling aggregation without any grouping (no group-by).
class	AggSvcGroupAllNoAccessImpl Implementation for handling aggregation without any grouping (no group-by).
class	AggSvcGroupByAccessOnlyImpl Aggregation service for use when only first/last/window aggregation functions are used an none other.
class	AggSvcGroupByLocalGroupBy Implementation for handling aggregation with grouping by group-keys.
class	AggSvcGroupByMixedAccessImpl Implementation for handling aggregation with grouping by group-keys.
class	AggSvcGroupByNoAccessImpl Implementation for handling aggregation with grouping by group-keys.
class	AggSvcGroupByReclaimAgedImpl Implementation for handling aggregation with grouping by group-keys.
class	AggSvcGroupByRefcountedNoAccessImpl Implementation for handling aggregation with grouping by group-keys.
class	AggSvcGroupByRefcountedWAccessImpl Implementation for handling aggregation with grouping by group-keys.
class	AggSvcGroupByRefcountedWAccessRollupImpl Implementation for handling aggregation with grouping by group-keys.
class	AggSvcGroupByWTableBase Implementation for handling aggregation with grouping by group-keys.
class	AggSvcGroupByWTableImpl Implementation for handling aggregation with grouping by group-keys.
class	AggSvcGroupByWTableRollupMultiKeyImpl Implementation for handling aggregation with grouping by group-keys.
class	AggSvcGroupByWTableRollupSingleKeyImpl Implementation for handling aggregation with grouping by group-keys.
class	AggSvcGroupLocalGroupByBase Implementation for handling aggregation with grouping by group-keys.

Methods in com.espertech.esper.epl.agg.service that return AggregationService

AggregationService	AggSvcGroupByWTableFactory.makeService(AgentInstanceContext agentInstanceContext, MethodResolutionService methodResolutionService)
AggregationService	AggSvcGroupByRefcountedWAccessRollupFactory.makeService(AgentInstanceContext agentInstanceContext, MethodResolutionService methodResolutionService)
AggregationService	AggSvcGroupByRefcountedWAccessFactory.makeService(AgentInstanceContext agentInstanceContext, MethodResolutionService methodResolutionService)
AggregationService	AggSvcGroupByRefcountedNoAccessFactory.makeService(AgentInstanceContext agentInstanceContext, MethodResolutionService methodResolutionService)
AggregationService	AggSvcGroupByReclaimAgedFactory.makeService(AgentInstanceContext agentInstanceContext, MethodResolutionService methodResolutionService)
AggregationService	AggSvcGroupByNoAccessFactory.makeService(AgentInstanceContext agentInstanceContext, MethodResolutionService methodResolutionService)
AggregationService	AggSvcGroupByMixedAccessFactory.makeService(AgentInstanceContext agentInstanceContext, MethodResolutionService methodResolutionService)
AggregationService	AggSvcGroupByLocalGroupByFactory.makeService(AgentInstanceContext agentInstanceContext, MethodResolutionService methodResolutionService)
AggregationService	AggSvcGroupByAccessOnlyFactory.makeService(AgentInstanceContext agentInstanceContext, MethodResolutionService methodResolutionService)
AggregationService	AggSvcGroupAllNoAccessFactory.makeService(AgentInstanceContext agentInstanceContext, MethodResolutionService methodResolutionService)
AggregationService	AggSvcGroupAllMixedAccessWTableFactory.makeService(AgentInstanceContext agentInstanceContext, MethodResolutionService methodResolutionService)
AggregationService	AggSvcGroupAllMixedAccessFactory.makeService(AgentInstanceContext agentInstanceContext, MethodResolutionService methodResolutionService)
AggregationService	AggSvcGroupAllLocalGroupByFactory.makeService(AgentInstanceContext agentInstanceContext, MethodResolutionService methodResolutionService)
AggregationService	AggSvcGroupAllAccessOnlyFactory.makeService(AgentInstanceContext agentInstanceContext, MethodResolutionService methodResolutionService)
AggregationService	AggregationServiceNullFactory.makeService(AgentInstanceContext agentInstanceContext, MethodResolutionService methodResolutionService)
AggregationService	AggregationServiceFactory.makeService(AgentInstanceContext agentInstanceContext, MethodResolutionService methodResolutionService)

Uses of AggregationService in com.espertech.esper.epl.core

Fields in com.espertech.esper.epl.core declared as AggregationService

protected AggregationService	ResultSetProcessorRowPerGroupRollup.aggregationService
protected AggregationService	ResultSetProcessorRowPerGroup.aggregationService

Methods in com.espertech.esper.epl.core with parameters of type AggregationService

static void	ResultSetProcessorUtil.applyAggJoinResult(AggregationService aggregationService, ExprEvaluatorContext exprEvaluatorContext, java.util.Set<MultiKey<EventBean>> newEvents, java.util.Set<MultiKey<EventBean>> oldEvents)
static void	ResultSetProcessorUtil.applyAggViewResult(AggregationService aggregationService, ExprEvaluatorContext exprEvaluatorContext, EventBean[] newData, EventBean[] oldData, EventBean[] eventsPerStream)
static void	ResultSetProcessorUtil.clearAndAggregateUngrouped(ExprEvaluatorContext exprEvaluatorContext, AggregationService aggregationService, Viewable parent)
OrderByProcessor	OrderByProcessorRowLimitOnlyFactory.instantiate(AggregationService aggregationService, AgentInstanceContext agentInstanceContext)
OrderByProcessor	OrderByProcessorOrderedLimitFactory.instantiate(AggregationService aggregationService, AgentInstanceContext agentInstanceContext)
OrderByProcessor	OrderByProcessorFactoryImpl.instantiate(AggregationService aggregationService, AgentInstanceContext agentInstanceContext)
OrderByProcessor	OrderByProcessorFactory.instantiate(AggregationService aggregationService, AgentInstanceContext agentInstanceContext)
ResultSetProcessor	ResultSetProcessorSimpleFactory.instantiate(OrderByProcessor orderByProcessor, AggregationService aggregationService, AgentInstanceContext agentInstanceContext)
ResultSetProcessor	ResultSetProcessorRowPerGroupRollupFactory.instantiate(OrderByProcessor orderByProcessor, AggregationService aggregationService, AgentInstanceContext agentInstanceContext)
ResultSetProcessor	ResultSetProcessorRowPerGroupFactory.instantiate(OrderByProcessor orderByProcessor, AggregationService aggregationService, AgentInstanceContext agentInstanceContext)
ResultSetProcessor	ResultSetProcessorRowForAllFactory.instantiate(OrderByProcessor orderByProcessor, AggregationService aggregationService, AgentInstanceContext agentInstanceContext)
ResultSetProcessor	ResultSetProcessorHandThrougFactory.instantiate(OrderByProcessor orderByProcessor, AggregationService aggregationService, AgentInstanceContext agentInstanceContext)
ResultSetProcessor	ResultSetProcessorFactory.instantiate(OrderByProcessor orderByProcessor, AggregationService aggregationService, AgentInstanceContext agentInstanceContext)
ResultSetProcessor	ResultSetProcessorAggregateGroupedFactory.instantiate(OrderByProcessor orderByProcessor, AggregationService aggregationService, AgentInstanceContext agentInstanceContext)
ResultSetProcessor	ResultSetProcessorAggregateAllFactory.instantiate(OrderByProcessor orderByProcessor, AggregationService aggregationService, AgentInstanceContext agentInstanceContext)

Constructors in com.espertech.esper.epl.core with parameters of type AggregationService

OrderByProcessorImpl(OrderByProcessorFactoryImpl factory, AggregationService aggregationService)

ResultSetAggregateGroupedIterator(java.util.Iterator<EventBean> sourceIterator, ResultSetProcessorAggregateGrouped resultSetProcessor, AggregationService aggregationService, ExprEvaluatorContext exprEvaluatorContext)
Ctor.

ResultSetProcessorAggregateAll(ResultSetProcessorAggregateAllFactory prototype, SelectExprProcessor selectExprProcessor, OrderByProcessor orderByProcessor, AggregationService aggregationService, ExprEvaluatorContext exprEvaluatorContext)

ResultSetProcessorAggregateGrouped(ResultSetProcessorAggregateGroupedFactory prototype, SelectExprProcessor selectExprProcessor, OrderByProcessor orderByProcessor, AggregationService aggregationService, AgentInstanceContext agentInstanceContext)

ResultSetProcessorRowForAll(ResultSetProcessorRowForAllFactory prototype, SelectExprProcessor selectExprProcessor, OrderByProcessor orderByProcessor, AggregationService aggregationService, ExprEvaluatorContext exprEvaluatorContext)

ResultSetProcessorRowPerGroup(ResultSetProcessorRowPerGroupFactory prototype, SelectExprProcessor selectExprProcessor, OrderByProcessor orderByProcessor, AggregationService aggregationService, AgentInstanceContext agentInstanceContext)

ResultSetProcessorRowPerGroupRollup(ResultSetProcessorRowPerGroupRollupFactory prototype, OrderByProcessor orderByProcessor, AggregationService aggregationService, AgentInstanceContext agentInstanceContext)

ResultSetProcessorRowPerGroupRollupUnbound(ResultSetProcessorRowPerGroupRollupFactory prototype, OrderByProcessor orderByProcessor, AggregationService aggregationService, AgentInstanceContext agentInstanceContext)

ResultSetProcessorRowPerGroupUnbound(ResultSetProcessorRowPerGroupFactory prototype, SelectExprProcessor selectExprProcessor, OrderByProcessor orderByProcessor, AggregationService aggregationService, AgentInstanceContext agentInstanceContext)

ResultSetRowPerGroupIterator(java.util.Iterator<EventBean> sourceIterator, ResultSetProcessorRowPerGroup resultSetProcessor, AggregationService aggregationService, ExprEvaluatorContext exprEvaluatorContext)
Ctor.

Uses of AggregationService in com.espertech.esper.epl.expression.subquery

Fields in com.espertech.esper.epl.expression.subquery declared as AggregationService

protected AggregationService

ExprSubselectNode.subselectAggregationService

Methods in com.espertech.esper.epl.expression.subquery that return AggregationService

AggregationService

ExprSubselectNode.getSubselectAggregationService()

Methods in com.espertech.esper.epl.expression.subquery with parameters of type AggregationService

void	ExprSubselectNode.setSubselectAggregationService(AggregationService subselectAggregationService)

Uses of AggregationService in com.espertech.esper.epl.subquery

Fields in com.espertech.esper.epl.subquery declared as AggregationService

protected AggregationService	SubselectAggregatorViewBase.aggregationService
protected AggregationService	SubselectAggregationPreprocessorBase.aggregationService

Constructors in com.espertech.esper.epl.subquery with parameters of type AggregationService

SubselectAggregationPreprocessorBase(AggregationService aggregationService, ExprEvaluator filterExpr, ExprEvaluator[] groupKeys)

SubselectAggregationPreprocessorFilteredGrouped(AggregationService aggregationService, ExprEvaluator filterExpr, ExprEvaluator[] groupKeys)

SubselectAggregationPreprocessorFilteredUngrouped(AggregationService aggregationService, ExprEvaluator filterExpr, ExprEvaluator[] groupKeys)

SubselectAggregationPreprocessorUnfilteredGrouped(AggregationService aggregationService, ExprEvaluator filterExpr, ExprEvaluator[] groupKeys)

SubselectAggregationPreprocessorUnfilteredUngrouped(AggregationService aggregationService, ExprEvaluator filterExpr, ExprEvaluator[] groupKeys)

SubselectAggregatorViewBase(AggregationService aggregationService, ExprEvaluator optionalFilterExpr, ExprEvaluatorContext exprEvaluatorContext, ExprEvaluator[] groupKeys)

SubselectAggregatorViewFilteredGrouped(AggregationService aggregationService, ExprEvaluator optionalFilterExpr, ExprEvaluatorContext exprEvaluatorContext, ExprEvaluator[] groupKeys, ExprNode filterExprNode)

SubselectAggregatorViewFilteredUngrouped(AggregationService aggregationService, ExprEvaluator optionalFilterExpr, ExprEvaluatorContext exprEvaluatorContext, ExprEvaluator[] groupKeys, ExprNode filterExprNode)

SubselectAggregatorViewUnfilteredGrouped(AggregationService aggregationService, ExprEvaluator optionalFilterExpr, ExprEvaluatorContext exprEvaluatorContext, ExprEvaluator[] groupKeys)

SubselectAggregatorViewUnfilteredUngrouped(AggregationService aggregationService, ExprEvaluator optionalFilterExpr, ExprEvaluatorContext exprEvaluatorContext, ExprEvaluator[] groupKeys)

Uses of AggregationService in com.espertech.esper.view.window

Fields in com.espertech.esper.view.window declared as AggregationService

protected AggregationService

ExpressionViewBase.aggregationService

Methods in com.espertech.esper.view.window that return AggregationService

AggregationService

ExpressionViewBase.getAggregationService()