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 |
Aggregation services.
|
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 |
AggregationAgentDefaultWFilter |
class |
AggregationAgentRewriteStream |
class |
AggregationAgentRewriteStreamWFilter |
Modifier and Type | Method and Description |
---|---|
AggregationAgent |
AggregationMethodFactorySum.getAggregationStateAgent(EngineImportService engineImportService,
String statementName) |
AggregationAgent |
AggregationMethodFactoryStddev.getAggregationStateAgent(EngineImportService engineImportService,
String statementName) |
AggregationAgent |
AggregationMethodFactoryRate.getAggregationStateAgent(EngineImportService engineImportService,
String statementName) |
AggregationAgent |
AggregationMethodFactoryPlugIn.getAggregationStateAgent(EngineImportService engineImportService,
String statementName) |
AggregationAgent |
AggregationMethodFactoryNth.getAggregationStateAgent(EngineImportService engineImportService,
String statementName) |
AggregationAgent |
AggregationMethodFactoryMinMax.getAggregationStateAgent(EngineImportService engineImportService,
String statementName) |
AggregationAgent |
AggregationMethodFactoryMedian.getAggregationStateAgent(EngineImportService engineImportService,
String statementName) |
AggregationAgent |
AggregationMethodFactoryLeaving.getAggregationStateAgent(EngineImportService engineImportService,
String statementName) |
AggregationAgent |
AggregationMethodFactoryLastEver.getAggregationStateAgent(EngineImportService engineImportService,
String statementName) |
AggregationAgent |
AggregationMethodFactoryFirstEver.getAggregationStateAgent(EngineImportService engineImportService,
String statementName) |
AggregationAgent |
AggregationMethodFactoryCountEver.getAggregationStateAgent(EngineImportService engineImportService,
String statementName) |
AggregationAgent |
AggregationMethodFactoryCount.getAggregationStateAgent(EngineImportService engineImportService,
String statementName) |
AggregationAgent |
AggregationMethodFactoryAvg.getAggregationStateAgent(EngineImportService engineImportService,
String statementName) |
AggregationAgent |
AggregationMethodFactoryAvedev.getAggregationStateAgent(EngineImportService engineImportService,
String statementName) |
Modifier and Type | Method and Description |
---|---|
AggregationAgent |
AggregationMethodFactory.getAggregationStateAgent(EngineImportService engineImportService,
String statementName) |
Modifier and Type | Method and Description |
---|---|
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupWBinding(TableMetadata tableMetadata,
TableColumnMethodPair[] methodPairs,
AggregationAccessorSlotPair[] accessorPairs,
boolean join,
IntoTableSpec bindings,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgent[] agents,
AggregationGroupByRollupDesc groupByRollupDesc) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupWBinding(TableMetadata tableMetadata,
TableColumnMethodPair[] methodPairs,
AggregationAccessorSlotPair[] accessorPairs,
boolean join,
IntoTableSpec bindings,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgent[] agents,
AggregationGroupByRollupDesc groupByRollupDesc) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getNoGroupWBinding(AggregationAccessorSlotPair[] accessors,
boolean join,
TableColumnMethodPair[] methodPairs,
String tableName,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgent[] agents) |
AggregationServiceFactory |
AggregationServiceFactoryService.getNoGroupWBinding(AggregationAccessorSlotPair[] accessors,
boolean join,
TableColumnMethodPair[] methodPairs,
String tableName,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgent[] agents) |
Modifier and Type | Class and Description |
---|---|
class |
CountMinSketchAggAgentAdd |
class |
CountMinSketchAggAgentAddFilter |
Modifier and Type | Method and Description |
---|---|
AggregationAgent |
ExprPlugInAggMultiFunctionNodeFactory.getAggregationStateAgent(EngineImportService engineImportService,
String statementName) |
AggregationAgent |
ExprAggMultiFunctionSortedMinMaxByNodeFactory.getAggregationStateAgent(EngineImportService engineImportService,
String statementName) |
AggregationAgent |
ExprAggMultiFunctionLinearAccessNodeFactoryAccess.getAggregationStateAgent(EngineImportService engineImportService,
String statementName) |
AggregationAgent |
ExprAggCountMinSketchNodeFactoryUse.getAggregationStateAgent(EngineImportService engineImportService,
String statementName) |
AggregationAgent |
ExprAggCountMinSketchNodeFactoryState.getAggregationStateAgent(EngineImportService engineImportService,
String statementName) |
AggregationAgent |
AggregationMethodFactoryFirstLastUnbound.getAggregationStateAgent(EngineImportService engineImportService,
String statementName) |
static AggregationAgent |
ExprAggAggregationAgentFactory.make(int streamNum,
ExprNode optionalFilter,
EngineImportService engineImportService,
boolean isFireAndForget,
String statementName) |
Constructor and Description |
---|
ExprAggMultiFunctionLinearAccessNodeFactoryAccess(ExprAggMultiFunctionLinearAccessNode parent,
AggregationAccessor accessor,
Class accessorResultType,
EventType containedEventType,
AggregationStateKey optionalStateKey,
AggregationStateFactory optionalStateFactory,
AggregationAgent optionalAgent) |
ExprAggMultiFunctionSortedMinMaxByNodeFactory(ExprAggMultiFunctionSortedMinMaxByNode parent,
AggregationAccessor accessor,
Class accessorResultType,
EventType containedEventType,
AggregationStateKey optionalStateKey,
SortedAggregationStateFactoryFactory optionalStateFactory,
AggregationAgent optionalAgent) |
Modifier and Type | Method and Description |
---|---|
AggregationAgent |
PlugInAggregationMultiFunctionHandler.getAggregationAgent(PlugInAggregationMultiFunctionAgentContext agentContext) |