|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.espertech.esper.epl.core.ResultSetProcessorBaseSimple
com.espertech.esper.epl.core.ResultSetProcessorHandThrough
public class ResultSetProcessorHandThrough
Result set processor for the hand-through case: no aggregation functions used in the select clause, and no group-by, no having and ordering.
Constructor Summary | |
---|---|
ResultSetProcessorHandThrough(SelectExprProcessor selectExprProcessor,
boolean isSelectRStream)
Ctor. |
Method Summary | |
---|---|
void |
clear()
Clear out current state. |
Iterator<EventBean> |
getIterator(Set<MultiKey<EventBean>> joinSet)
Returns the iterator for iterating over a join-result. |
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. |
EventType |
getResultEventType()
Returns the event type of processed results. |
protected static EventBean[] |
getSelectEventsNoHaving(SelectExprProcessor exprProcessor,
EventBean[] events,
boolean isNewData,
boolean isSynthesize)
Applies the select-clause to the given events returning the selected events. |
protected static EventBean[] |
getSelectEventsNoHaving(SelectExprProcessor exprProcessor,
Set<MultiKey<EventBean>> events,
boolean isNewData,
boolean isSynthesize)
Applies the select-clause to the given events returning the selected events. |
UniformPair<EventBean[]> |
processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isSynthesize)
For use by joins posting their result, process the event rows that are entered and removed (new and old events). |
UniformPair<EventBean[]> |
processViewResult(EventBean[] newData,
EventBean[] oldData,
boolean isSynthesize)
For use by views posting their result, process the event rows that are entered and removed (new and old events). |
Methods inherited from class com.espertech.esper.epl.core.ResultSetProcessorBaseSimple |
---|
processOutputLimitedJoin, processOutputLimitedView |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public ResultSetProcessorHandThrough(SelectExprProcessor selectExprProcessor, boolean isSelectRStream)
selectExprProcessor
- - for processing the select expression and generting the final output rows
a row per group even if groups didn't changeisSelectRStream
- - true if remove stream events should be generatedMethod Detail |
---|
public EventType getResultEventType()
ResultSetProcessor
public UniformPair<EventBean[]> processJoinResult(Set<MultiKey<EventBean>> newEvents, Set<MultiKey<EventBean>> oldEvents, boolean isSynthesize)
ResultSetProcessor
newEvents
- - new events posted by joinoldEvents
- - old events posted by joinisSynthesize
- - set to true to indicate that synthetic events are required for an iterator result set
public UniformPair<EventBean[]> processViewResult(EventBean[] newData, EventBean[] oldData, boolean isSynthesize)
ResultSetProcessor
newData
- - new events posted by viewoldData
- - old events posted by viewisSynthesize
- - set to true to indicate that synthetic events are required for an iterator result set
protected static EventBean[] getSelectEventsNoHaving(SelectExprProcessor exprProcessor, EventBean[] events, boolean isNewData, boolean isSynthesize)
exprProcessor
- - processes each input event and returns output eventevents
- - input eventsisNewData
- - indicates whether we are dealing with new data (istream) or old data (rstream)isSynthesize
- - set to true to indicate that synthetic events are required for an iterator result set
protected static EventBean[] getSelectEventsNoHaving(SelectExprProcessor exprProcessor, Set<MultiKey<EventBean>> events, boolean isNewData, boolean isSynthesize)
exprProcessor
- - processes each input event and returns output eventevents
- - input eventsisNewData
- - indicates whether we are dealing with new data (istream) or old data (rstream)isSynthesize
- - set to true to indicate that synthetic events are required for an iterator result set
public void clear()
ResultSetProcessor
clear
in interface ResultSetProcessor
clear
in class ResultSetProcessorBaseSimple
public Iterator<EventBean> getIterator(Viewable parent)
ResultSetProcessor
parent
- is the parent view iterator
public Iterator<EventBean> getIterator(Set<MultiKey<EventBean>> joinSet)
ResultSetProcessor
joinSet
- is the join result set
|
© 2007 EsperTech Inc. All rights reserved. Visit us at espertech.com |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |