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.orderby | |
com.espertech.esper.epl.core.resultset.agggrouped |
Result set processor for Aggregated and Grouped
|
com.espertech.esper.epl.core.resultset.core |
Result set processor Core classes
|
com.espertech.esper.epl.core.resultset.grouped |
Result set processor utility classes for general grouped-aggregation
|
com.espertech.esper.epl.core.resultset.handthru |
Result set processor for Un-Aggregated and Un-Grouped with having or output-rate-limiting or order-by
|
com.espertech.esper.epl.core.resultset.rowforall |
Result set processor for Fully-Aggregated and Un-Grouped
|
com.espertech.esper.epl.core.resultset.rowperevent |
Result set processor for Aggregated and Un-Grouped
|
com.espertech.esper.epl.core.resultset.rowpergroup |
Result set processor for Fully-Aggregated and Grouped
|
com.espertech.esper.epl.core.resultset.rowpergrouprollup |
Result set processor for Rollup
|
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
|
Modifier and Type | Method and Description |
---|---|
AggregationService |
StatementAgentInstanceFactoryResult.getOptionalAggegationService() |
AggregationService |
StatementAgentInstanceFactoryOnTriggerBase.OnExprViewResult.getOptionalAggregationService() |
Modifier and Type | Interface and Description |
---|---|
interface |
AIRegistryAggregation |
Modifier and Type | Class and Description |
---|---|
class |
AIRegistryAggregationMap |
class |
AIRegistryAggregationMultiPerm |
class |
AIRegistryAggregationSingle |
Modifier and Type | Method and Description |
---|---|
AggregationService |
AIRegistryAggregationSingle.getContextPartitionAggregationService(int agentInstanceId) |
AggregationService |
AIRegistryAggregationMultiPerm.getContextPartitionAggregationService(int agentInstanceId) |
AggregationService |
AIRegistryAggregationMap.getContextPartitionAggregationService(int agentInstanceId) |
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) |
Modifier and Type | Method and Description |
---|---|
AggregationService |
SubSelectStrategyRealization.getSubselectAggregationService() |
AggregationService |
SubSelectStrategyHolder.getSubselectAggregationService() |
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) |
Modifier and Type | Method and Description |
---|---|
AggregationService |
StatementResourceHolder.getAggregationService() |
Modifier and Type | Method and Description |
---|---|
protected void |
StatementResourceHolder.setAggregationService(AggregationService aggregationService) |
Modifier and Type | Method and Description |
---|---|
static Pair<ResultSetProcessor,AggregationService> |
EPStatementStartMethodHelperUtil.startResultSetAndAggregation(ResultSetProcessorFactoryDesc resultSetProcessorPrototype,
AgentInstanceContext agentInstanceContext,
boolean isSubquery,
Integer subqueryNumber) |
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) |
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.
|
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) |
Modifier and Type | Method and Description |
---|---|
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) |
Constructor and Description |
---|
OrderByProcessorImpl(OrderByProcessorFactoryImpl factory,
AggregationService aggregationService) |
Modifier and Type | Field and Description |
---|---|
protected AggregationService |
ResultSetProcessorAggregateGroupedImpl.aggregationService |
Modifier and Type | Method and Description |
---|---|
AggregationService |
ResultSetProcessorAggregateGroupedImpl.getAggregationService() |
AggregationService |
ResultSetProcessorAggregateGrouped.getAggregationService() |
Modifier and Type | Method and Description |
---|---|
ResultSetProcessor |
ResultSetProcessorAggregateGroupedFactory.instantiate(OrderByProcessor orderByProcessor,
AggregationService aggregationService,
AgentInstanceContext agentInstanceContext) |
Constructor and Description |
---|
ResultSetProcessorAggregateGroupedIterator(Iterator<EventBean> sourceIterator,
ResultSetProcessorAggregateGrouped resultSetProcessor,
AggregationService aggregationService,
ExprEvaluatorContext exprEvaluatorContext)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
static void |
ResultSetProcessorUtil.applyAggJoinResult(AggregationService aggregationService,
ExprEvaluatorContext exprEvaluatorContext,
Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
static void |
ResultSetProcessorUtil.applyAggViewResult(AggregationService aggregationService,
ExprEvaluatorContext exprEvaluatorContext,
EventBean[] newData,
EventBean[] oldData,
EventBean[] eventsPerStream)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
static void |
ResultSetProcessorUtil.clearAndAggregateUngrouped(ExprEvaluatorContext exprEvaluatorContext,
AggregationService aggregationService,
Viewable parent) |
ResultSetProcessor |
ResultSetProcessorFactory.instantiate(OrderByProcessor orderByProcessor,
AggregationService aggregationService,
AgentInstanceContext agentInstanceContext) |
Modifier and Type | Method and Description |
---|---|
static void |
ResultSetProcessorGroupedUtil.applyAggJoinResultKeyedJoin(AggregationService aggregationService,
AgentInstanceContext agentInstanceContext,
Set<MultiKey<EventBean>> newEvents,
Object[] newDataMultiKey,
Set<MultiKey<EventBean>> oldEvents,
Object[] oldDataMultiKey)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
static void |
ResultSetProcessorGroupedUtil.applyAggViewResultKeyedView(AggregationService aggregationService,
AgentInstanceContext agentInstanceContext,
EventBean[] newData,
Object[] newDataMultiKey,
EventBean[] oldData,
Object[] oldDataMultiKey,
EventBean[] eventsPerStream)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
Modifier and Type | Method and Description |
---|---|
ResultSetProcessor |
ResultSetProcessorSimpleFactory.instantiate(OrderByProcessor orderByProcessor,
AggregationService aggregationService,
AgentInstanceContext agentInstanceContext) |
Modifier and Type | Field and Description |
---|---|
protected AggregationService |
ResultSetProcessorRowForAllImpl.aggregationService |
Modifier and Type | Method and Description |
---|---|
AggregationService |
ResultSetProcessorRowForAllImpl.getAggregationService() |
AggregationService |
ResultSetProcessorRowForAll.getAggregationService() |
Modifier and Type | Method and Description |
---|---|
ResultSetProcessor |
ResultSetProcessorRowForAllFactory.instantiate(OrderByProcessor orderByProcessor,
AggregationService aggregationService,
AgentInstanceContext agentInstanceContext) |
Modifier and Type | Method and Description |
---|---|
ResultSetProcessor |
ResultSetProcessorRowPerEventFactory.instantiate(OrderByProcessor orderByProcessor,
AggregationService aggregationService,
AgentInstanceContext agentInstanceContext) |
Modifier and Type | Field and Description |
---|---|
protected AggregationService |
ResultSetProcessorRowPerGroupImpl.aggregationService |
Modifier and Type | Method and Description |
---|---|
AggregationService |
ResultSetProcessorRowPerGroupImpl.getAggregationService() |
AggregationService |
ResultSetProcessorRowPerGroup.getAggregationService() |
Modifier and Type | Method and Description |
---|---|
ResultSetProcessor |
ResultSetProcessorRowPerGroupFactory.instantiate(OrderByProcessor orderByProcessor,
AggregationService aggregationService,
AgentInstanceContext agentInstanceContext) |
Constructor and Description |
---|
ResultSetProcessorRowPerGroupIterator(Iterator<EventBean> sourceIterator,
ResultSetProcessorRowPerGroup resultSetProcessor,
AggregationService aggregationService,
ExprEvaluatorContext exprEvaluatorContext)
Ctor.
|
Modifier and Type | Field and Description |
---|---|
protected AggregationService |
ResultSetProcessorRowPerGroupRollupImpl.aggregationService |
Modifier and Type | Method and Description |
---|---|
AggregationService |
ResultSetProcessorRowPerGroupRollupImpl.getAggregationService() |
AggregationService |
ResultSetProcessorRowPerGroupRollup.getAggregationService() |
Modifier and Type | Method and Description |
---|---|
ResultSetProcessor |
ResultSetProcessorRowPerGroupRollupFactory.instantiate(OrderByProcessor orderByProcessor,
AggregationService aggregationService,
AgentInstanceContext agentInstanceContext) |
Modifier and Type | Field and Description |
---|---|
protected AggregationService |
ExprSubselectNode.subselectAggregationService |
Modifier and Type | Method and Description |
---|---|
AggregationService |
ExprSubselectNode.getSubselectAggregationService() |
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) |
Modifier and Type | Field and Description |
---|---|
protected AggregationService |
SubselectAggregatorViewBase.aggregationService |
protected AggregationService |
SubselectAggregationPreprocessorBase.aggregationService |
Modifier and Type | Field and Description |
---|---|
protected AggregationService |
ExpressionViewBase.aggregationService |
Modifier and Type | Method and Description |
---|---|
AggregationService |
ExpressionViewBase.getAggregationService() |