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.table |
Aggregation services - table aggregation.
|
com.espertech.esper.epl.agg.util |
Aggregation utility classes centered around local group-by parameters.
|
Modifier and Type | Method and Description |
---|---|
AggregationAccessorSlotPairForge[] |
AggregationCodegenRowDetailDesc.getAccessAccessors() |
Constructor and Description |
---|
AggregationCodegenRowDetailDesc(AggregationCodegenRowDetailStateDesc stateDesc,
AggregationAccessorSlotPairForge[] accessAccessors) |
Modifier and Type | Method and Description |
---|---|
AggregationAccessorSlotPairForge[] |
AggregationRowStateForgeDesc.getAccessAccessorsForges() |
AggregationAccessorSlotPairForge[] |
AggregationMultiFunctionAnalysisResult.getAccessorPairsForge() |
Modifier and Type | Method and Description |
---|---|
static AggregationAccessorSlotPair |
AggregatorUtil.getAccessorForForge(AggregationAccessorSlotPairForge pair,
EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
static AggregationAccessorSlotPair[] |
AggregatorUtil.getAccessorsForForges(AggregationAccessorSlotPairForge[] accessors,
EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
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) |
Constructor and Description |
---|
AggregationMultiFunctionAnalysisResult(AggregationAccessorSlotPairForge[] accessorPairsForge,
AggregationStateFactoryForge[] stateFactoryForges) |
AggregationRowStateForgeDesc(ExprForge[][] methodForges,
AggregationMethodFactory[] methodFactories,
AggregationAccessorSlotPairForge[] accessAccessorsForges,
AggregationStateFactoryForge[] accessFactoriesForges) |
Constructor and Description |
---|
AggSvcGroupByWTableForge(TableService tableService,
TableMetadata tableMetadata,
TableColumnMethodPair[] methodPairs,
AggregationAccessorSlotPairForge[] accessorForges,
AggregationAccessorSlotPair[] accessors,
boolean join,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgentForge[] agentForges,
AggregationAgent[] agents,
AggregationGroupByRollupDesc groupByRollupDesc,
boolean hasGroupBy) |
Modifier and Type | Method and Description |
---|---|
AggregationAccessorSlotPairForge |
AggregationLocalGroupByColumnForge.getPair() |
Modifier and Type | Method and Description |
---|---|
static AggregationLocalGroupByPlanForge |
AggregationGroupByLocalGroupByAnalyzer.analyze(ExprForge[][] methodForges,
AggregationMethodFactory[] methodFactories,
AggregationStateFactoryForge[] accessAggregations,
AggregationGroupByLocalGroupDesc localGroupDesc,
ExprNode[] groupByExpressions,
AggregationAccessorSlotPairForge[] accessors,
EngineImportService engineImportService,
boolean fireAndForget,
java.lang.String statementName) |
Constructor and Description |
---|
AggregationLocalGroupByColumnForge(boolean defaultGroupLevel,
ExprForge[] partitionForges,
int methodOffset,
boolean methodAgg,
AggregationAccessorSlotPairForge pair,
int levelNum) |