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

Packages that use AggregationService

Package	Description
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

Modifier and Type	Method and Description
AggregationService	StatementAgentInstanceFactoryResult.getOptionalAggegationService()
AggregationService	StatementAgentInstanceFactoryOnTriggerBase.OnExprViewResult.getOptionalAggregationService()

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

Constructor and Description
OnExprViewResult(View onExprView, AggregationService optionalAggregationService)
StatementAgentInstanceFactoryOnTriggerResult(Viewable finalView, StopCallback stopCallback, AgentInstanceContext agentInstanceContext, AggregationService aggregationService, Map<ExprSubselectNode,SubSelectStrategyHolder> subselectStrategies, EvalRootState optPatternRoot, Map<ExprTableAccessNode,ExprTableAccessEvalStrategy> tableAccessStrategies, ViewableActivationResult viewableActivationResult)
StatementAgentInstanceFactoryResult(Viewable finalView, StopCallback stopCallback, AgentInstanceContext agentInstanceContext, AggregationService optionalAggegationService, Map<ExprSubselectNode,SubSelectStrategyHolder> subselectStrategies, Map<ExprPriorNode,ExprPriorEvalStrategy> priorNodeStrategies, Map<ExprPreviousNode,ExprPreviousEvalStrategy> previousNodeStrategies, RegexExprPreviousEvalStrategy regexExprPreviousEvalStrategy, Map<ExprTableAccessNode,ExprTableAccessEvalStrategy> tableAccessStrategies, List<StatementAgentInstancePreload> preloadList)
StatementAgentInstanceFactorySelectResult(Viewable finalView, StopCallback stopCallback, AgentInstanceContext agentInstanceContext, AggregationService optionalAggegationService, Map<ExprSubselectNode,SubSelectStrategyHolder> subselectStrategies, Map<ExprPriorNode,ExprPriorEvalStrategy> priorNodeStrategies, Map<ExprPreviousNode,ExprPreviousEvalStrategy> previousNodeStrategies, RegexExprPreviousEvalStrategy regexExprPreviousEvalStrategy, Map<ExprTableAccessNode,ExprTableAccessEvalStrategy> tableAccessStrategies, List<StatementAgentInstancePreload> preloadList, EvalRootState[] patternRoots, StatementAgentInstancePostLoad optionalPostLoadJoin, Viewable[] topViews, Viewable[] eventStreamViewables, ViewableActivationResult[] viewableActivationResults)

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

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

Modifier and Type	Interface and Description
interface	AIRegistryAggregation

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

Modifier and Type	Class and Description
class	AIRegistryAggregationMap
class	AIRegistryAggregationMultiPerm
class	AIRegistryAggregationSingle

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

Modifier and Type	Method and Description
AggregationService	AIRegistryAggregationSingle.getContextPartitionAggregationService(int agentInstanceId)
AggregationService	AIRegistryAggregationMultiPerm.getContextPartitionAggregationService(int agentInstanceId)
AggregationService	AIRegistryAggregationMap.getContextPartitionAggregationService(int agentInstanceId)

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

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
AggregationService	SubSelectStrategyRealization.getSubselectAggregationService()
AggregationService	SubSelectStrategyHolder.getSubselectAggregationService()

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

Constructor and Description
SubSelectStrategyHolder(ExprSubselectStrategy stategy, AggregationService subselectAggregationService, Map<ExprPriorNode,ExprPriorEvalStrategy> priorStrategies, Map<ExprPreviousNode,ExprPreviousEvalStrategy> previousNodeStrategies, Viewable subselectView, StatementAgentInstancePostLoad postLoad, ViewableActivationResult subselectActivationResult)
SubSelectStrategyRealization(SubordTableLookupStrategy strategy, SubselectAggregationPreprocessorBase subselectAggregationPreprocessor, AggregationService subselectAggregationService, Map<ExprPriorNode,ExprPriorEvalStrategy> priorNodeStrategies, 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

Modifier and Type	Method and Description
AggregationService	StatementResourceHolder.getAggregationService()

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

Modifier and Type	Method and Description
protected void	StatementResourceHolder.setAggregationService(AggregationService aggregationService)

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

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

Modifier and Type	Method and Description
static Pair<ResultSetProcessor,AggregationService>	EPStatementStartMethodHelperUtil.startResultSetAndAggregation(ResultSetProcessorFactoryDesc resultSetProcessorPrototype, AgentInstanceContext agentInstanceContext, boolean isSubquery, Integer subqueryNumber)

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

Modifier and Type

Method and Description

static void

EPStatementStartMethodHelperAssignExpr.assignExpressionStrategies(EPStatementStartMethodSelectDesc selectDesc, AggregationService aggregationService, Map<ExprSubselectNode,SubSelectStrategyHolder> subselectStrategyInstances, Map<ExprPriorNode,ExprPriorEvalStrategy> priorStrategyInstances, Map<ExprPreviousNode,ExprPreviousEvalStrategy> previousStrategyInstances, Set<ExprPreviousMatchRecognizeNode> matchRecognizeNodes, RegexExprPreviousEvalStrategy matchRecognizePrevEvalStrategy, 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

Modifier and Type	Class and Description
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

Modifier and Type	Method and Description
AggregationService	AggSvcGroupLocalGroupByBase.getContextPartitionAggregationService(int agentInstanceId)
AggregationService	AggSvcGroupByWTableBase.getContextPartitionAggregationService(int agentInstanceId)
AggregationService	AggSvcGroupByAccessOnlyImpl.getContextPartitionAggregationService(int agentInstanceId)
AggregationService	AggSvcGroupAllMixedAccessWTableImpl.getContextPartitionAggregationService(int agentInstanceId)
AggregationService	AggSvcGroupAllAccessOnlyImpl.getContextPartitionAggregationService(int agentInstanceId)
AggregationService	AggregationServiceTable.getContextPartitionAggregationService(int agentInstanceId)
AggregationService	AggregationServiceNull.getContextPartitionAggregationService(int agentInstanceId)
AggregationService	AggregationServiceBaseUngrouped.getContextPartitionAggregationService(int agentInstanceId)
AggregationService	AggregationServiceBaseGrouped.getContextPartitionAggregationService(int agentInstanceId)
AggregationService	AggregationService.getContextPartitionAggregationService(int agentInstanceId)
AggregationService	AggSvcGroupByWTableFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggSvcGroupByRefcountedWAccessRollupFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggSvcGroupByRefcountedWAccessFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggSvcGroupByRefcountedNoAccessFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggSvcGroupByReclaimAgedFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggSvcGroupByNoAccessFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggSvcGroupByMixedAccessFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggSvcGroupByLocalGroupByFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggSvcGroupByAccessOnlyFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggSvcGroupAllNoAccessFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggSvcGroupAllMixedAccessWTableFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggSvcGroupAllMixedAccessFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggSvcGroupAllLocalGroupByFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggSvcGroupAllAccessOnlyFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggregationServiceNullFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggregationServiceFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)

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

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

Modifier and Type	Field and Description
protected AggregationService	ResultSetProcessorRowPerGroupRollup.aggregationService
protected AggregationService	ResultSetProcessorRowPerGroup.aggregationService
protected AggregationService	ResultSetProcessorRowForAll.aggregationService
protected AggregationService	ResultSetProcessorAggregateGrouped.aggregationService

Methods in com.espertech.esper.epl.core that return AggregationService

Modifier and Type	Method and Description
AggregationService	ResultSetProcessorRowPerGroupRollup.getAggregationService()
AggregationService	ResultSetProcessorRowPerGroup.getAggregationService()
AggregationService	ResultSetProcessorRowForAll.getAggregationService()
AggregationService	ResultSetProcessorAggregateGrouped.getAggregationService()

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

Modifier and Type	Method and Description
static void	ResultSetProcessorUtil.applyAggJoinResult(AggregationService aggregationService, ExprEvaluatorContext exprEvaluatorContext, Set<MultiKey<EventBean>> newEvents, 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	ResultSetProcessorHandThroughFactory.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

Constructor and Description
OrderByProcessorImpl(OrderByProcessorFactoryImpl factory, AggregationService aggregationService)
ResultSetAggregateGroupedIterator(Iterator<EventBean> sourceIterator, ResultSetProcessorAggregateGrouped resultSetProcessor, AggregationService aggregationService, ExprEvaluatorContext exprEvaluatorContext) Ctor.
ResultSetProcessorAggregateAll(ResultSetProcessorAggregateAllFactory prototype, SelectExprProcessor selectExprProcessor, OrderByProcessor orderByProcessor, AggregationService aggregationService, AgentInstanceContext agentInstanceContext)
ResultSetProcessorAggregateGrouped(ResultSetProcessorAggregateGroupedFactory prototype, SelectExprProcessor selectExprProcessor, OrderByProcessor orderByProcessor, AggregationService aggregationService, AgentInstanceContext agentInstanceContext)
ResultSetProcessorRowForAll(ResultSetProcessorRowForAllFactory prototype, SelectExprProcessor selectExprProcessor, OrderByProcessor orderByProcessor, AggregationService aggregationService, AgentInstanceContext agentInstanceContext)
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(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

Modifier and Type	Field and Description
protected AggregationService	ExprSubselectNode.subselectAggregationService

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

Modifier and Type	Method and Description
AggregationService	ExprSubselectNode.getSubselectAggregationService()

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

Modifier and Type	Method and Description
Object	SubselectEvalStrategyNRExistsWGroupByWHaving.evaluate(EventBean[] eventsPerStream, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext, AggregationService aggregationServiceAnyPartition)
Object	SubselectEvalStrategyNRExistsWGroupBy.evaluate(EventBean[] eventsPerStream, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext, AggregationService aggregationService)
Object	SubselectEvalStrategyNRExistsDefault.evaluate(EventBean[] eventsPerStream, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext, AggregationService aggregationService)
Object	SubselectEvalStrategyNRExistsAlwaysTrue.evaluate(EventBean[] eventsPerStream, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext, AggregationService aggregationService)
Object	SubselectEvalStrategyNRExistsAggregated.evaluate(EventBean[] eventsPerStream, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext, AggregationService aggregationService)
Object	SubselectEvalStrategyNRBase.evaluate(EventBean[] eventsPerStream, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext, AggregationService aggregationService)
Object	SubselectEvalStrategyNR.evaluate(EventBean[] eventsPerStream, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext, AggregationService aggregationService) Evaluate.
protected Object	SubselectEvalStrategyNRRelOpAnyWGroupBy.evaluateInternal(Object leftResult, EventBean[] events, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext, AggregationService aggregationServiceAnyPartition)
protected Object	SubselectEvalStrategyNRRelOpAnyDefault.evaluateInternal(Object leftResult, EventBean[] events, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext, AggregationService aggregationService)
protected Object	SubselectEvalStrategyNRRelOpAllWGroupBy.evaluateInternal(Object leftResult, EventBean[] events, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext, AggregationService aggregationServiceAnyPartition)
protected Object	SubselectEvalStrategyNRRelOpAllDefault.evaluateInternal(Object leftResult, EventBean[] events, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext, AggregationService aggregationService)
protected Object	SubselectEvalStrategyNRRelOpAllAnyAggregated.evaluateInternal(Object leftResult, EventBean[] events, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext, AggregationService aggregationService)
protected Object	SubselectEvalStrategyNREqualsInWGroupBy.evaluateInternal(Object leftResult, EventBean[] events, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext, AggregationService aggregationServiceAnyPartition)
protected Object	SubselectEvalStrategyNREqualsInUnfiltered.evaluateInternal(Object leftResult, EventBean[] events, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext, AggregationService aggregationService)
protected Object	SubselectEvalStrategyNREqualsInFiltered.evaluateInternal(Object leftResult, EventBean[] eventsZeroOffset, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext, AggregationService aggregationService)
protected Object	SubselectEvalStrategyNREqualsInAggregated.evaluateInternal(Object leftResult, EventBean[] events, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext, AggregationService aggregationService)
protected Object	SubselectEvalStrategyNREqualsAnyWGroupBy.evaluateInternal(Object leftResult, EventBean[] events, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext, AggregationService aggregationServiceAnyPartition)
protected Object	SubselectEvalStrategyNREqualsAnyDefault.evaluateInternal(Object leftResult, EventBean[] events, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext, AggregationService aggregationService)
protected Object	SubselectEvalStrategyNREqualsAllWGroupBy.evaluateInternal(Object leftResult, EventBean[] events, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext, AggregationService aggregationServiceAnyPartition)
protected Object	SubselectEvalStrategyNREqualsAllDefault.evaluateInternal(Object leftResult, EventBean[] events, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext, AggregationService aggregationService)
protected Object	SubselectEvalStrategyNREqualsAllAnyAggregated.evaluateInternal(Object leftResult, EventBean[] events, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext, AggregationService aggregationService)
protected abstract Object	SubselectEvalStrategyNRBase.evaluateInternal(Object leftResult, EventBean[] events, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext, AggregationService 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

Modifier and Type	Field and Description
protected AggregationService	SubselectAggregatorViewBase.aggregationService
protected AggregationService	SubselectAggregationPreprocessorBase.aggregationService

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

Constructor and Description
SubselectAggregationPreprocessorBase(AggregationService aggregationService, ExprEvaluator filterEval, ExprEvaluator[] groupKeys)
SubselectAggregationPreprocessorFilteredGrouped(AggregationService aggregationService, ExprEvaluator filterEval, ExprEvaluator[] groupKeys)
SubselectAggregationPreprocessorFilteredUngrouped(AggregationService aggregationService, ExprEvaluator filterEval, ExprEvaluator[] groupKeys)
SubselectAggregationPreprocessorUnfilteredGrouped(AggregationService aggregationService, ExprEvaluator filterEval, ExprEvaluator[] groupKeys)
SubselectAggregationPreprocessorUnfilteredUngrouped(AggregationService aggregationService, ExprEvaluator filterEval, 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

Modifier and Type	Field and Description
protected AggregationService	ExpressionViewBase.aggregationService

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

Modifier and Type	Method and Description
AggregationService	ExpressionViewBase.getAggregationService()