|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.esper.eql.core.ResultSetProcessorAggregateAll
public class ResultSetProcessorAggregateAll
Result set processor for the case: aggregation functions used in the select clause, and no group-by, and not all of the properties in the select clause are under an aggregation function.
This processor does not perform grouping, every event entering and leaving is in the same group. The processor generates one row for each event entering (new event) and one row for each event leaving (old event). Aggregation state is simply one row holding all the state.
Constructor Summary | |
---|---|
ResultSetProcessorAggregateAll(SelectExprProcessor selectExprProcessor,
OrderByProcessor orderByProcessor,
AggregationService aggregationService,
ExprNode optionalHavingNode,
boolean isOutputLimiting,
boolean isOutputLimitLastOnly)
Ctor. |
Method Summary | |
---|---|
Iterator<EventBean> |
getIterator(Viewable parent)
Returns the iterator implementing the group-by and aggregation and order-by logic specific to each case of use of these construct. |
ExprNode |
getOptionalHavingNode()
Returns the optional having expression. |
EventType |
getResultEventType()
Returns the event type of processed results. |
SelectExprProcessor |
getSelectExprProcessor()
Returns the select expression processor |
Pair<EventBean[],EventBean[]> |
processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
For use by joins posting their result, process the event rows that are entered and removed (new and old events). |
Pair<EventBean[],EventBean[]> |
processViewResult(EventBean[] newData,
EventBean[] oldData)
For use by views posting their result, process the event rows that are entered and removed (new and old events). |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public ResultSetProcessorAggregateAll(SelectExprProcessor selectExprProcessor, OrderByProcessor orderByProcessor, AggregationService aggregationService, ExprNode optionalHavingNode, boolean isOutputLimiting, boolean isOutputLimitLastOnly)
selectExprProcessor
- - for processing the select expression and generting the final output rowsorderByProcessor
- - for sorting the outgoing events according to the order-by clauseaggregationService
- - handles aggregationoptionalHavingNode
- - having clause expression nodeisOutputLimiting
- - true to indicate that we limit outputisOutputLimitLastOnly
- - true to indicate that we limit output to the last eventMethod Detail |
---|
public EventType getResultEventType()
ResultSetProcessor
getResultEventType
in interface ResultSetProcessor
public Pair<EventBean[],EventBean[]> processJoinResult(Set<MultiKey<EventBean>> newEvents, Set<MultiKey<EventBean>> oldEvents)
ResultSetProcessor
processJoinResult
in interface ResultSetProcessor
newEvents
- - new events posted by joinoldEvents
- - old events posted by join
public Pair<EventBean[],EventBean[]> processViewResult(EventBean[] newData, EventBean[] oldData)
ResultSetProcessor
processViewResult
in interface ResultSetProcessor
newData
- - new events posted by viewoldData
- - old events posted by view
public Iterator<EventBean> getIterator(Viewable parent)
ResultSetProcessor
getIterator
in interface ResultSetProcessor
parent
- is the parent view iterator
public SelectExprProcessor getSelectExprProcessor()
public ExprNode getOptionalHavingNode()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |