Package | Description |
---|---|
com.espertech.esper.epl.agg.service |
Aggregation services.
|
com.espertech.esper.epl.agg.util |
Aggregation utility classes centered around local group-by parameters.
|
Modifier and Type | Field and Description |
---|---|
protected AggregationLocalGroupByPlan |
AggSvcGroupLocalGroupByBase.localGroupByPlan |
protected AggregationLocalGroupByPlan |
AggSvcGroupByLocalGroupByFactory.localGroupByPlan |
Modifier and Type | Method and Description |
---|---|
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.getNoGroupLocalGroupBy(boolean join,
AggregationLocalGroupByPlan localGroupByPlan,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getNoGroupLocalGroupBy(boolean join,
AggregationLocalGroupByPlan localGroupByPlan,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
Constructor and Description |
---|
AggSvcGroupAllLocalGroupBy(boolean isJoin,
AggregationLocalGroupByPlan localGroupByPlan) |
AggSvcGroupAllLocalGroupByFactory(boolean join,
AggregationLocalGroupByPlan localGroupByPlan) |
AggSvcGroupByLocalGroupBy(boolean isJoin,
AggregationLocalGroupByPlan localGroupByPlan) |
AggSvcGroupByLocalGroupByFactory(boolean join,
AggregationLocalGroupByPlan localGroupByPlan) |
AggSvcGroupLocalGroupByBase(boolean isJoin,
AggregationLocalGroupByPlan localGroupByPlan) |
Modifier and Type | Method and Description |
---|---|
static AggregationLocalGroupByPlan |
AggregationGroupByLocalGroupByAnalyzer.analyze(ExprEvaluator[] evaluators,
AggregationMethodFactory[] prototypes,
AggregationStateFactory[] accessAggregations,
AggregationGroupByLocalGroupDesc localGroupDesc,
ExprNode[] groupByExpressions,
AggregationAccessorSlotPair[] accessors,
EngineImportService engineImportService,
boolean fireAndForget,
String statementName) |
Modifier and Type | Method and Description |
---|---|
void |
AggregationLocalLevelHook.planned(AggregationGroupByLocalGroupDesc localGroupDesc,
AggregationLocalGroupByPlan localGroupByPlan) |