Package | Description |
---|---|
com.espertech.esper.epl.agg.access |
State multifunction aggregation methods
|
com.espertech.esper.epl.agg.factory |
Aggregator factories
|
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.
|
com.espertech.esper.epl.expression.accessagg |
Access-aggregation expressions.
|
com.espertech.esper.plugin |
APIs for plug-in adapter (for input-output) and plug-in event representation (event types and event objects) are in
this package.
|
Modifier and Type | Class and Description |
---|---|
class |
AggregationAgentDefault |
class |
AggregationAgentDefaultWFilterForge |
class |
AggregationAgentRewriteStream |
class |
AggregationAgentRewriteStreamWFilterForge |
Modifier and Type | Method and Description |
---|---|
AggregationAgentForge |
AggregationMethodFactorySum.getAggregationStateAgent(EngineImportService engineImportService,
java.lang.String statementName) |
AggregationAgentForge |
AggregationMethodFactoryStddev.getAggregationStateAgent(EngineImportService engineImportService,
java.lang.String statementName) |
AggregationAgentForge |
AggregationMethodFactoryRate.getAggregationStateAgent(EngineImportService engineImportService,
java.lang.String statementName) |
AggregationAgentForge |
AggregationMethodFactoryPlugIn.getAggregationStateAgent(EngineImportService engineImportService,
java.lang.String statementName) |
AggregationAgentForge |
AggregationMethodFactoryNth.getAggregationStateAgent(EngineImportService engineImportService,
java.lang.String statementName) |
AggregationAgentForge |
AggregationMethodFactoryMinMax.getAggregationStateAgent(EngineImportService engineImportService,
java.lang.String statementName) |
AggregationAgentForge |
AggregationMethodFactoryMedian.getAggregationStateAgent(EngineImportService engineImportService,
java.lang.String statementName) |
AggregationAgentForge |
AggregationMethodFactoryLeaving.getAggregationStateAgent(EngineImportService engineImportService,
java.lang.String statementName) |
AggregationAgentForge |
AggregationMethodFactoryFirstLastEver.getAggregationStateAgent(EngineImportService engineImportService,
java.lang.String statementName) |
AggregationAgentForge |
AggregationMethodFactoryCountEver.getAggregationStateAgent(EngineImportService engineImportService,
java.lang.String statementName) |
AggregationAgentForge |
AggregationMethodFactoryCount.getAggregationStateAgent(EngineImportService engineImportService,
java.lang.String statementName) |
AggregationAgentForge |
AggregationMethodFactoryAvg.getAggregationStateAgent(EngineImportService engineImportService,
java.lang.String statementName) |
AggregationAgentForge |
AggregationMethodFactoryAvedev.getAggregationStateAgent(EngineImportService engineImportService,
java.lang.String statementName) |
Modifier and Type | Method and Description |
---|---|
AggregationAgentForge |
AggregationMethodFactory.getAggregationStateAgent(EngineImportService engineImportService,
java.lang.String statementName) |
Modifier and Type | Method and Description |
---|---|
static AggregationAgent[] |
AggregatorUtil.getAgentForges(AggregationAgentForge[] agentForges,
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) |
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) |
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 | Class and Description |
---|---|
class |
CountMinSketchAggAgentAddForge |
Modifier and Type | Method and Description |
---|---|
AggregationAgentForge |
ExprPlugInAggMultiFunctionNodeFactory.getAggregationStateAgent(EngineImportService engineImportService,
java.lang.String statementName) |
AggregationAgentForge |
ExprAggMultiFunctionSortedMinMaxByNodeFactory.getAggregationStateAgent(EngineImportService engineImportService,
java.lang.String statementName) |
AggregationAgentForge |
ExprAggMultiFunctionLinearAccessNodeFactoryAccess.getAggregationStateAgent(EngineImportService engineImportService,
java.lang.String statementName) |
AggregationAgentForge |
ExprAggCountMinSketchNodeFactoryUse.getAggregationStateAgent(EngineImportService engineImportService,
java.lang.String statementName) |
AggregationAgentForge |
ExprAggCountMinSketchNodeFactoryState.getAggregationStateAgent(EngineImportService engineImportService,
java.lang.String statementName) |
AggregationAgentForge |
AggregationMethodFactoryFirstLastUnbound.getAggregationStateAgent(EngineImportService engineImportService,
java.lang.String statementName) |
static AggregationAgentForge |
ExprAggAggregationAgentFactory.make(int streamNum,
ExprNode optionalFilter,
EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
Constructor and Description |
---|
ExprAggMultiFunctionLinearAccessNodeFactoryAccess(ExprAggMultiFunctionLinearAccessNode parent,
AggregationAccessorForge accessor,
java.lang.Class accessorResultType,
EventType containedEventType,
AggregationStateKey optionalStateKey,
AggregationStateFactoryForge optionalStateFactory,
AggregationAgentForge optionalAgent) |
ExprAggMultiFunctionSortedMinMaxByNodeFactory(ExprAggMultiFunctionSortedMinMaxByNode parent,
AggregationAccessorForge accessor,
java.lang.Class accessorResultType,
EventType containedEventType,
AggregationStateKey optionalStateKey,
SortedAggregationStateFactoryFactory optionalStateFactory,
AggregationAgentForge optionalAgent) |
Modifier and Type | Method and Description |
---|---|
AggregationAgentForge |
PlugInAggregationMultiFunctionHandler.getAggregationAgent(PlugInAggregationMultiFunctionAgentContext agentContext) |