Package | Description |
---|---|
com.espertech.esper.epl.agg.service |
Aggregation services.
|
Modifier and Type | Class and Description |
---|---|
class |
AggregationServiceFactoryBase
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 |
AggregationServiceNullFactory
A null object implementation of the AggregationService
interface.
|
class |
AggSvcGroupAllAccessOnlyFactory
Aggregation service for use when only first/last/window aggregation functions are used an none other.
|
class |
AggSvcGroupAllLocalGroupByFactory
Implementation for handling aggregation with grouping by group-keys.
|
class |
AggSvcGroupAllMixedAccessFactory
Implementation for handling aggregation without any grouping (no group-by).
|
class |
AggSvcGroupAllMixedAccessWTableFactory
Implementation for handling aggregation without any grouping (no group-by).
|
class |
AggSvcGroupAllNoAccessFactory
Implementation for handling aggregation without any grouping (no group-by).
|
class |
AggSvcGroupByAccessOnlyFactory
Aggregation service for use when only first/last/window aggregation functions are used an none other.
|
class |
AggSvcGroupByLocalGroupByFactory |
class |
AggSvcGroupByMixedAccessFactory
Implementation for handling aggregation with grouping by group-keys.
|
class |
AggSvcGroupByNoAccessFactory
Implementation for handling aggregation with grouping by group-keys.
|
class |
AggSvcGroupByReclaimAgedFactory
Implementation for handling aggregation with grouping by group-keys.
|
class |
AggSvcGroupByRefcountedNoAccessFactory
Implementation for handling aggregation with grouping by group-keys.
|
class |
AggSvcGroupByRefcountedWAccessFactory
Implementation for handling aggregation with grouping by group-keys.
|
class |
AggSvcGroupByRefcountedWAccessRollupFactory
Implementation for handling aggregation with grouping by group-keys.
|
class |
AggSvcGroupByWTableFactory
Implementation for handling aggregation with grouping by group-keys.
|
Modifier and Type | Method and Description |
---|---|
AggregationServiceFactory |
AggregationServiceFactoryDesc.getAggregationServiceFactory() |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupedNoReclaimNoAccess(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupedNoReclaimNoAccess(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupLocalGroupBy(boolean join,
AggregationLocalGroupByPlan localGroupByPlan,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupLocalGroupBy(boolean join,
AggregationLocalGroupByPlan localGroupByPlan,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupNoReclaimAccessOnly(ExprNode[] groupByNodes,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggSpecs,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupNoReclaimAccessOnly(ExprNode[] groupByNodes,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggSpecs,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupNoReclaimMixed(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupNoReclaimMixed(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupReclaimAged(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
Hint reclaimGroupAged,
Hint reclaimGroupFrequency,
VariableService variableService,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
String optionalContextName,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupReclaimAged(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
Hint reclaimGroupAged,
Hint reclaimGroupFrequency,
VariableService variableService,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
String optionalContextName,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupReclaimMixable(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupReclaimMixable(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupReclaimMixableRollup(ExprNode[] groupByNodes,
AggregationGroupByRollupDesc byRollupDesc,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
AggregationGroupByRollupDesc groupByRollupDesc,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupReclaimMixableRollup(ExprNode[] groupByNodes,
AggregationGroupByRollupDesc byRollupDesc,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
AggregationGroupByRollupDesc groupByRollupDesc,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupReclaimNoAccess(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupReclaimNoAccess(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupWBinding(TableMetadata tableMetadata,
TableColumnMethodPair[] methodPairs,
AggregationAccessorSlotPair[] accessorPairs,
boolean join,
IntoTableSpec bindings,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgent[] agents,
AggregationGroupByRollupDesc groupByRollupDesc) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupWBinding(TableMetadata tableMetadata,
TableColumnMethodPair[] methodPairs,
AggregationAccessorSlotPair[] accessorPairs,
boolean join,
IntoTableSpec bindings,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgent[] agents,
AggregationGroupByRollupDesc groupByRollupDesc) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getNoGroupAccessMixed(ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getNoGroupAccessMixed(ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getNoGroupAccessOnly(AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggSpecs,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getNoGroupAccessOnly(AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggSpecs,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getNoGroupLocalGroupBy(boolean join,
AggregationLocalGroupByPlan localGroupByPlan,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getNoGroupLocalGroupBy(boolean join,
AggregationLocalGroupByPlan localGroupByPlan,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getNoGroupNoAccess(ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getNoGroupNoAccess(ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getNoGroupWBinding(AggregationAccessorSlotPair[] accessors,
boolean join,
TableColumnMethodPair[] methodPairs,
String tableName,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgent[] agents) |
AggregationServiceFactory |
AggregationServiceFactoryService.getNoGroupWBinding(AggregationAccessorSlotPair[] accessors,
boolean join,
TableColumnMethodPair[] methodPairs,
String tableName,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgent[] agents) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getNullAggregationService() |
AggregationServiceFactory |
AggregationServiceFactoryService.getNullAggregationService() |
Constructor and Description |
---|
AggregationServiceFactoryDesc(AggregationServiceFactory aggregationServiceFactory,
List<AggregationServiceAggExpressionDesc> expressions,
List<ExprAggregateNodeGroupKey> groupKeyExpressions) |