|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.esper.eql.expression.ResultSetProcessorSimple
public class ResultSetProcessorSimple
Result set processor for the simplest case: no aggregation functions used in the select clause, and no group-by.
The processor generates one row for each event entering (new event) and one row for each event leaving (old event).
Constructor Summary | |
---|---|
ResultSetProcessorSimple(SelectExprProcessor selectExprProcessor,
OrderByProcessor orderByProcessor,
boolean isOutputLimiting,
boolean isOutputLimitLastOnly)
Ctor. |
Method Summary | |
---|---|
protected static EventBean[] |
applyOutputLimit(EventBean[] events,
boolean isOutputLimitLastOnly)
Applies the last/all event output limit clause. |
protected static Set<MultiKey<EventBean>> |
applyOutputLimit(Set<MultiKey<EventBean>> eventSet,
boolean isOutputLimitLastOnly)
Applies the last/all event output limit clause. |
EventType |
getResultEventType()
Returns the event type of processed results. |
protected static EventBean[] |
getSelectListEvents(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
EventBean[] events,
boolean isOutputLimiting,
boolean isOutputLimitLastOnly)
Applies the select-clause to the given events returning the selected events. |
protected static EventBean[] |
getSelectListEvents(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
Set<MultiKey<EventBean>> events,
boolean isOutputLimiting,
boolean isOutputLimitLastOnly)
Applies the select-clause to the given events returning the selected events. |
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 ResultSetProcessorSimple(SelectExprProcessor selectExprProcessor, OrderByProcessor orderByProcessor, 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 clauseisOutputLimiting
- - true to indicate we are output limiting and must keep producing
a row per group even if groups didn't changeisOutputLimitLastOnly
- - true if output limiting and interested in last event onlyMethod 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
protected static EventBean[] getSelectListEvents(SelectExprProcessor exprProcessor, OrderByProcessor orderByProcessor, EventBean[] events, boolean isOutputLimiting, boolean isOutputLimitLastOnly)
exprProcessor
- - processes each input event and returns output eventorderByProcessor
- - orders the outgoing events according to the order-by clauseevents
- - input eventsisOutputLimiting
- - true to indicate that we limit outputisOutputLimitLastOnly
- - true to indicate that we limit output to the last event
protected static EventBean[] applyOutputLimit(EventBean[] events, boolean isOutputLimitLastOnly)
events
- to outputisOutputLimitLastOnly
- - flag to indicate output all versus output last
protected static Set<MultiKey<EventBean>> applyOutputLimit(Set<MultiKey<EventBean>> eventSet, boolean isOutputLimitLastOnly)
eventSet
- to outputisOutputLimitLastOnly
- - flag to indicate output all versus output last
protected static EventBean[] getSelectListEvents(SelectExprProcessor exprProcessor, OrderByProcessor orderByProcessor, Set<MultiKey<EventBean>> events, boolean isOutputLimiting, boolean isOutputLimitLastOnly)
exprProcessor
- - processes each input event and returns output eventorderByProcessor
- - for sorting output events according to the order-by clauseevents
- - input eventsisOutputLimiting
- - true to indicate that we limit outputisOutputLimitLastOnly
- - true to indicate that we limit output to the last event
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |