| Package | Description |
|---|---|
| com.espertech.esper.epl.agg.service |
Aggregation services.
|
| com.espertech.esper.epl.expression.accessagg |
Access-aggregation expressions.
|
| com.espertech.esper.epl.expression.baseagg |
Base aggregation expressions.
|
| com.espertech.esper.epl.expression.core |
Core expression classes.
|
| com.espertech.esper.epl.expression.methodagg |
Method-aggregation expressions.
|
| com.espertech.esper.epl.table.mgmt |
Table-related services and metadata.
|
| com.espertech.esper.metrics.instrumentation |
EPL instrumentation helpers.
|
| Modifier and Type | Method and Description |
|---|---|
ExprAggregateNode |
AggregationServiceAggExpressionDesc.getAggregationNode()
Returns the expression.
|
| Modifier and Type | Method and Description |
|---|---|
List<ExprAggregateNode> |
AggregationServiceAggExpressionDesc.getEquivalentNodes()
Returns the equivalent aggregation functions.
|
| Modifier and Type | Method and Description |
|---|---|
void |
AggregationServiceAggExpressionDesc.addEquivalent(ExprAggregateNode aggNodeToAdd)
Add an equivalent aggregation function node
|
| Modifier and Type | Method and Description |
|---|---|
static AggregationServiceFactoryDesc |
AggregationServiceFactoryFactory.getService(List<ExprAggregateNode> selectAggregateExprNodes,
Map<ExprNode,String> selectClauseNamedNodes,
List<ExprDeclaredNode> declaredExpressions,
ExprNode[] groupByNodes,
List<ExprAggregateNode> havingAggregateExprNodes,
List<ExprAggregateNode> orderByAggregateExprNodes,
List<ExprAggregateNodeGroupKey> groupKeyExpressions,
boolean hasGroupByClause,
Annotation[] annotations,
VariableService variableService,
boolean isJoin,
boolean isDisallowNoReclaim,
ExprNode whereClause,
ExprNode havingClause,
AggregationServiceFactoryService factoryService,
EventType[] typesPerStream,
AggregationGroupByRollupDesc groupByRollupDesc,
String optionalContextName,
IntoTableSpec intoTableSpec,
TableService tableService,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect,
EngineImportService engineImportService,
String statementName) |
static AggregationServiceFactoryDesc |
AggregationServiceFactoryFactory.getService(List<ExprAggregateNode> selectAggregateExprNodes,
Map<ExprNode,String> selectClauseNamedNodes,
List<ExprDeclaredNode> declaredExpressions,
ExprNode[] groupByNodes,
List<ExprAggregateNode> havingAggregateExprNodes,
List<ExprAggregateNode> orderByAggregateExprNodes,
List<ExprAggregateNodeGroupKey> groupKeyExpressions,
boolean hasGroupByClause,
Annotation[] annotations,
VariableService variableService,
boolean isJoin,
boolean isDisallowNoReclaim,
ExprNode whereClause,
ExprNode havingClause,
AggregationServiceFactoryService factoryService,
EventType[] typesPerStream,
AggregationGroupByRollupDesc groupByRollupDesc,
String optionalContextName,
IntoTableSpec intoTableSpec,
TableService tableService,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect,
EngineImportService engineImportService,
String statementName) |
static AggregationServiceFactoryDesc |
AggregationServiceFactoryFactory.getService(List<ExprAggregateNode> selectAggregateExprNodes,
Map<ExprNode,String> selectClauseNamedNodes,
List<ExprDeclaredNode> declaredExpressions,
ExprNode[] groupByNodes,
List<ExprAggregateNode> havingAggregateExprNodes,
List<ExprAggregateNode> orderByAggregateExprNodes,
List<ExprAggregateNodeGroupKey> groupKeyExpressions,
boolean hasGroupByClause,
Annotation[] annotations,
VariableService variableService,
boolean isJoin,
boolean isDisallowNoReclaim,
ExprNode whereClause,
ExprNode havingClause,
AggregationServiceFactoryService factoryService,
EventType[] typesPerStream,
AggregationGroupByRollupDesc groupByRollupDesc,
String optionalContextName,
IntoTableSpec intoTableSpec,
TableService tableService,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect,
EngineImportService engineImportService,
String statementName) |
static AggregationServiceMatchRecognizeFactoryDesc |
AggregationServiceFactoryFactory.getServiceMatchRecognize(int numStreams,
Map<Integer,List<ExprAggregateNode>> measureExprNodesPerStream,
EventType[] typesPerStream,
EngineImportService engineImportService,
String statementName)
Produces an aggregation service for use with match-recognice.
|
| Constructor and Description |
|---|
AggregationServiceAggExpressionDesc(ExprAggregateNode aggregationNode,
AggregationMethodFactory factory)
Ctor.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ExprAggCountMinSketchNode
Represents the Count-min sketch aggregate function.
|
class |
ExprAggMultiFunctionLinearAccessNode |
class |
ExprAggMultiFunctionSortedMinMaxByNode |
class |
ExprPlugInAggMultiFunctionNode
Represents a custom aggregation function in an expresson tree.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
ExprPlugInAggMultiFunctionNode.equalsNodeAggregateMethodOnly(ExprAggregateNode node) |
protected boolean |
ExprAggMultiFunctionSortedMinMaxByNode.equalsNodeAggregateMethodOnly(ExprAggregateNode node) |
protected boolean |
ExprAggMultiFunctionLinearAccessNode.equalsNodeAggregateMethodOnly(ExprAggregateNode node) |
boolean |
ExprAggCountMinSketchNode.equalsNodeAggregateMethodOnly(ExprAggregateNode node) |
| Modifier and Type | Class and Description |
|---|---|
class |
ExprAggregateNodeBase
Base expression node that represents an aggregation function such as 'sum' or 'count'.
|
| Modifier and Type | Method and Description |
|---|---|
protected abstract boolean |
ExprAggregateNodeBase.equalsNodeAggregateMethodOnly(ExprAggregateNode node)
Return true if a expression aggregate node semantically equals the current node, or false if not.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
ExprAggregateNodeUtil.getAggregatesBottomUp(ExprNode[][] nodes,
List<ExprAggregateNode> aggregateNodes) |
static void |
ExprAggregateNodeUtil.getAggregatesBottomUp(ExprNode[] nodes,
List<ExprAggregateNode> aggregateNodes) |
static void |
ExprAggregateNodeUtil.getAggregatesBottomUp(ExprNode topNode,
List<ExprAggregateNode> aggregateNodes)
Populates into the supplied list all aggregation functions within this expression, if any.
|
| Modifier and Type | Method and Description |
|---|---|
static ExprNodePropOrStreamSet |
ExprNodeUtility.getAggregatedProperties(List<ExprAggregateNode> aggregateNodes) |
| Modifier and Type | Class and Description |
|---|---|
class |
ExprAvedevNode
Represents the avedev(...) aggregate function is an expression tree.
|
class |
ExprAvgNode
Represents the avg(...) aggregate function is an expression tree.
|
class |
ExprCountEverNode
Represents the "countever" aggregate function is an expression tree.
|
class |
ExprCountNode
Represents the count(...) and count(*) and count(distinct ...) aggregate function is an expression tree.
|
class |
ExprFirstEverNode
Represents the "firstever" aggregate function is an expression tree.
|
class |
ExprLastEverNode
Represents the "lastever" aggregate function is an expression tree.
|
class |
ExprLeavingAggNode
Represents the leaving() aggregate function is an expression tree.
|
class |
ExprMedianNode
Represents the median(...) aggregate function is an expression tree.
|
class |
ExprMinMaxAggrNode
Represents the min/max(distinct? ...) aggregate function is an expression tree.
|
class |
ExprNthAggNode
Represents the nth(...) and aggregate function is an expression tree.
|
class |
ExprPlugInAggNode
Represents a custom aggregation function in an expresson tree.
|
class |
ExprRateAggNode
Represents the rate(...) and aggregate function is an expression tree.
|
class |
ExprStddevNode
Represents the stddev(...) aggregate function is an expression tree.
|
class |
ExprSumNode
Represents the sum(...) aggregate function is an expression tree.
|
| Modifier and Type | Method and Description |
|---|---|
ExprAggregateNode |
TableColumnDescAgg.getAggregation() |
| Constructor and Description |
|---|
TableColumnDescAgg(int positionInDeclaration,
String columnName,
ExprAggregateNode aggregation,
EventType optionalAssociatedType) |
| Modifier and Type | Method and Description |
|---|---|
void |
InstrumentationDefault.qExprTableSubpropAccessor(ExprNode exprNode,
String tableName,
String subpropName,
ExprAggregateNode aggregationExpression) |
void |
Instrumentation.qExprTableSubpropAccessor(ExprNode exprNode,
String tableName,
String subpropName,
ExprAggregateNode aggregationExpression) |