Package | Description |
---|---|
com.espertech.esper.epl.agg.codegen |
Byte-Code-Generation classes for aggregation service and related
|
com.espertech.esper.epl.agg.service.common |
Aggregation services - common.
|
com.espertech.esper.epl.agg.service.groupall |
Aggregation services group-all.
|
com.espertech.esper.epl.agg.service.groupby |
Aggregation services group-by regular
|
com.espertech.esper.epl.agg.service.groupbylocal |
Aggregation services - local-grouping
|
com.espertech.esper.epl.agg.service.groupbyrollup |
Aggregation services - rollup.
|
com.espertech.esper.epl.agg.service.table |
Aggregation services - table aggregation.
|
Modifier and Type | Method and Description |
---|---|
static AggregationServiceFactory |
AggregationServiceFactoryCompiler.allocate(AggregationServiceFactoryForge forge,
StatementContext stmtContext,
boolean isFireAndForget) |
static void |
AggregationServiceFactoryCompiler.makeInnerClasses(AggregationServiceFactoryForge forge,
CodegenClassScope classScope,
java.util.List<CodegenInnerClass> innerClasses,
java.lang.String providerClassName,
StatementContext statementContext,
boolean isFireAndForget) |
Modifier and Type | Class and Description |
---|---|
class |
AggregationServiceNullFactory
A null object implementation of the AggregationService
interface.
|
Modifier and Type | Method and Description |
---|---|
AggregationServiceFactoryForge |
AggregationServiceForgeDesc.getAggregationServiceFactoryForge() |
AggregationServiceFactoryForge |
AggregationServiceFactoryServiceImpl.getGroupBy(AggGroupByDesc aggGroupByDesc,
TimeAbacus timeAbacus,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactoryForge |
AggregationServiceFactoryService.getGroupBy(AggGroupByDesc aggGroupByDesc,
TimeAbacus timeAbacus,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactoryForge |
AggregationServiceFactoryServiceImpl.getGroupLocalGroupBy(boolean hasGroupByClause,
boolean join,
AggregationLocalGroupByPlanForge localGroupByPlan,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactoryForge |
AggregationServiceFactoryService.getGroupLocalGroupBy(boolean hasGroupByClause,
boolean join,
AggregationLocalGroupByPlanForge localGroupByPlan,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactoryForge |
AggregationServiceFactoryServiceImpl.getNoGroup(AggregationRowStateForgeDesc rowStateDesc,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactoryForge |
AggregationServiceFactoryService.getNoGroup(AggregationRowStateForgeDesc rowStateDesc,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactoryForge |
AggregationServiceFactoryServiceImpl.getNullAggregationService() |
AggregationServiceFactoryForge |
AggregationServiceFactoryService.getNullAggregationService() |
AggregationServiceFactoryForge |
AggregationServiceFactoryServiceImpl.getRollup(ExprNode[] groupByNodes,
AggregationGroupByRollupDesc rollupDesc,
AggregationRowStateForgeDesc rowStateDesc,
boolean join,
AggregationGroupByRollupDesc groupByRollupDesc,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactoryForge |
AggregationServiceFactoryService.getRollup(ExprNode[] groupByNodes,
AggregationGroupByRollupDesc rollupDesc,
AggregationRowStateForgeDesc rowStateDesc,
boolean join,
AggregationGroupByRollupDesc groupByRollupDesc,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactoryForge |
AggregationServiceFactoryServiceImpl.getTable(TableService tableService,
TableMetadata tableMetadata,
TableColumnMethodPair[] methodPairs,
AggregationAccessorSlotPairForge[] accessorPairs,
AggregationAccessorSlotPair[] accessors,
boolean join,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgentForge[] agentForges,
AggregationAgent[] agents,
AggregationGroupByRollupDesc groupByRollupDesc,
boolean hasGroupBy) |
AggregationServiceFactoryForge |
AggregationServiceFactoryService.getTable(TableService tableService,
TableMetadata tableMetadata,
TableColumnMethodPair[] methodPairs,
AggregationAccessorSlotPairForge[] accessorPairs,
AggregationAccessorSlotPair[] accessors,
boolean join,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgentForge[] agentForges,
AggregationAgent[] agents,
AggregationGroupByRollupDesc groupByRollupDesc,
boolean hasGroupBy) |
Modifier and Type | Method and Description |
---|---|
void |
AggregationServiceNullFactory.stopMethodCodegen(AggregationServiceFactoryForge forge,
CodegenMethodNode method) |
void |
AggregationServiceFactoryForge.stopMethodCodegen(AggregationServiceFactoryForge forge,
CodegenMethodNode method) |
Constructor and Description |
---|
AggregationServiceForgeDesc(AggregationServiceFactoryForge aggregationServiceFactoryForge,
java.util.List<AggregationServiceAggExpressionDesc> expressions,
java.util.List<ExprAggregateNodeGroupKey> groupKeyExpressions) |
Modifier and Type | Class and Description |
---|---|
class |
AggSvcGroupAllForge
Aggregation service for use when only first/last/window aggregation functions are used an none other.
|
Modifier and Type | Method and Description |
---|---|
void |
AggSvcGroupAllForge.stopMethodCodegen(AggregationServiceFactoryForge forge,
CodegenMethodNode method) |
Modifier and Type | Class and Description |
---|---|
class |
AggSvcGroupByForge
Implementation for handling aggregation with grouping by group-keys.
|
Modifier and Type | Method and Description |
---|---|
void |
AggSvcGroupByForge.stopMethodCodegen(AggregationServiceFactoryForge forge,
CodegenMethodNode method) |
Modifier and Type | Class and Description |
---|---|
class |
AggSvcLocalGroupByForge |
Modifier and Type | Method and Description |
---|---|
void |
AggSvcLocalGroupByForge.stopMethodCodegen(AggregationServiceFactoryForge forge,
CodegenMethodNode method) |
Modifier and Type | Class and Description |
---|---|
class |
AggSvcGroupByRollupForge
Implementation for handling aggregation with grouping by group-keys.
|
Modifier and Type | Method and Description |
---|---|
void |
AggSvcGroupByRollupForge.stopMethodCodegen(AggregationServiceFactoryForge forge,
CodegenMethodNode method) |
Modifier and Type | Class and Description |
---|---|
class |
AggSvcGroupByWTableForge
Implementation for handling aggregation with grouping by group-keys.
|
Modifier and Type | Method and Description |
---|---|
void |
AggSvcGroupByWTableForge.stopMethodCodegen(AggregationServiceFactoryForge forge,
CodegenMethodNode method) |