Package | Description |
---|---|
com.espertech.esper.core.context.stmt |
Registries for context partitions to handle aggregations, prev/prior and subselects.
|
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.expression.baseagg |
Base aggregation expressions.
|
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 |
---|---|
static void |
EPStatementStartMethodHelperAssignExpr.assignAggregations(AggregationResultFuture aggregationService,
List<AggregationServiceAggExpressionDesc> aggregationExpressions) |
Modifier and Type | Interface and Description |
---|---|
interface |
AggregationService
Service for maintaining aggregation state.
|
interface |
AggregationServiceMatchRecognize
Aggregation result future for use with match recognize.
|
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 |
AggregationServiceMatchRecognizeImpl
Implements an aggregation service for match recognize.
|
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 |
---|---|
void |
AggregationServiceAggExpressionDesc.assignFuture(AggregationResultFuture service)
Assigns a future to the expression
|
Modifier and Type | Field and Description |
---|---|
protected AggregationResultFuture |
ExprAggregateNodeBase.aggregationResultFuture |
Modifier and Type | Method and Description |
---|---|
void |
ExprAggregateNodeGroupKey.assignFuture(AggregationResultFuture future) |
void |
ExprAggregateNodeBase.setAggregationResultFuture(AggregationResultFuture aggregationResultFuture,
int column)
Assigns to the node the future which can be queried for the current aggregation state at evaluation time.
|
void |
ExprAggregateNode.setAggregationResultFuture(AggregationResultFuture aggregationResultFuture,
int column) |