|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use AggregationService | |
---|---|
net.esper.eql.core | Contains EQL statement specification classes define the constructs that make up an EQL statement, such as the list of items in the select clause, the insert-into stream name and property names etc. |
Uses of AggregationService in net.esper.eql.core |
---|
Classes in net.esper.eql.core that implement AggregationService | |
---|---|
class |
AggregationServiceBase
All aggregation services require evaluation nodes which supply the value to be aggregated (summed, averaged, etc.) and aggregation state factories to make new aggregation states. |
class |
AggregationServiceGroupAllImpl
Implementation for handling aggregation without any grouping (no group-by). |
class |
AggregationServiceGroupByImpl
Implementation for handling aggregation with grouping by group-keys. |
class |
AggregationServiceNull
A null object implementation of the AggregationService interface. |
Methods in net.esper.eql.core that return AggregationService | |
---|---|
static AggregationService |
AggregationServiceFactory.getService(List<ExprAggregateNode> aggregateExprNodes,
boolean hasGroupByClause,
ExprNode optionalHavingNode,
List<ExprNode> sortByNodes)
Returns an instance to handle the aggregation required by the aggregation expression nodes, depending on whether there are any group-by nodes. |
Methods in net.esper.eql.core with parameters of type AggregationService | |
---|---|
static OrderByProcessor |
OrderByProcessorFactory.getProcessor(List<SelectExprElementNamedSpec> selectionList,
List<ExprNode> groupByNodes,
List<Pair<ExprNode,Boolean>> orderByList,
AggregationService aggregationService,
EventAdapterService eventAdapterService)
Returns processor for order-by clauses. |
Constructors in net.esper.eql.core with parameters of type AggregationService | |
---|---|
OrderByProcessorSimple(List<Pair<ExprNode,Boolean>> orderByList,
List<ExprNode> groupByNodes,
boolean needsGroupByKeys,
AggregationService aggregationService)
Ctor. |
|
ResultSetProcessorAggregateAll(SelectExprProcessor selectExprProcessor,
OrderByProcessor orderByProcessor,
AggregationService aggregationService,
ExprNode optionalHavingNode,
boolean isOutputLimiting,
boolean isOutputLimitLastOnly)
Ctor. |
|
ResultSetProcessorAggregateGrouped(SelectExprProcessor selectExprProcessor,
OrderByProcessor orderByProcessor,
AggregationService aggregationService,
List<ExprNode> groupKeyNodes,
ExprNode optionalHavingNode,
boolean isOutputLimiting,
boolean isOutputLimitLastOnly)
Ctor. |
|
ResultSetProcessorRowForAll(SelectExprProcessor selectExprProcessor,
AggregationService aggregationService,
ExprNode optionalHavingNode)
Ctor. |
|
ResultSetProcessorRowPerGroup(SelectExprProcessor selectExprProcessor,
OrderByProcessor orderByProcessor,
AggregationService aggregationService,
List<ExprNode> groupKeyNodes,
ExprNode optionalHavingNode,
boolean isOutputLimiting,
boolean isOutputLimitLastOnly)
Ctor. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |