Package | Description |
---|---|
com.espertech.esper.epl.agg.access |
State multifunction aggregation methods
|
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.approx |
Approximation algos.
|
Modifier and Type | Class and Description |
---|---|
class |
AggregationAgentDefault |
class |
AggregationAgentDefaultWFilter |
class |
AggregationAgentRewriteStream |
class |
AggregationAgentRewriteStreamWFilter |
Modifier and Type | Method and Description |
---|---|
AggregationAgent |
AggregationAgentRewriteStreamWFilterForge.makeAgent(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
AggregationAgent |
AggregationAgentRewriteStream.makeAgent(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
AggregationAgent |
AggregationAgentForge.makeAgent(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
AggregationAgent |
AggregationAgentDefaultWFilterForge.makeAgent(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
AggregationAgent |
AggregationAgentDefault.makeAgent(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
Modifier and Type | Method and Description |
---|---|
static AggregationAgent[] |
AggregatorUtil.getAgentForges(AggregationAgentForge[] agentForges,
EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
Modifier and Type | Method and Description |
---|---|
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 |
---|---|
static CodegenMethodNode |
AggSvcGroupAllWTableImpl.applyCodegen(boolean enter,
CodegenMethodScope parent,
CodegenClassScope classScope,
TableColumnMethodPair[] methodPairs,
AggregationAgentForge[] agentForges,
AggregationAgent[] agents,
int[] targetStates) |
static CodegenMethodNode |
AggSvcGroupByWTableBase.applyGroupKeyCodegen(boolean enter,
CodegenMethodNode parent,
CodegenClassScope classScope,
TableColumnMethodPair[] methodPairs,
AggregationAgentForge[] agentForges,
AggregationAgent[] agents,
int[] targetStates) |
static CodegenMethodNode |
AggSvcGroupByWTableRollupSingleKeyImpl.applyRollupCodegen(boolean enter,
CodegenMethodNode parent,
CodegenClassScope classScope,
CodegenNamedMethods namedMethods,
TableColumnMethodPair[] methodPairs,
AggregationAgentForge[] agentForges,
AggregationAgent[] agents,
int[] targetStates,
AggregationGroupByRollupDesc groupByRollupDesc,
int numTableKeys) |
static CodegenMethodNode |
AggSvcGroupByWTableRollupMultiKeyImpl.applyRollupCodegen(boolean enter,
CodegenMethodNode parent,
CodegenClassScope classScope,
CodegenNamedMethods namedMethods,
TableColumnMethodPair[] methodPairs,
AggregationAgentForge[] agentForges,
AggregationAgent[] agents,
int[] targetStates,
AggregationGroupByRollupDesc groupByRollupDesc,
int numTableKeys) |
static CodegenExpression[] |
AggSvcGroupByWTableUtil.getAccessEnterLeave(boolean enter,
AggregationAgentForge[] agentForges,
AggregationAgent[] agents,
CodegenMethodNode method,
AggregationAgentCodegenSymbols symbols,
CodegenClassScope classScope) |
Modifier and Type | Class and Description |
---|---|
class |
CountMinSketchAggAgentAdd |
class |
CountMinSketchAggAgentAddFilter |
Modifier and Type | Method and Description |
---|---|
AggregationAgent |
CountMinSketchAggAgentAddForge.makeAgent(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |