|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface OrderByProcessor
A processor for ordering output events according to the order specified in the order-by clause.
Method Summary | |
---|---|
MultiKeyUntyped |
getSortKey(EventBean[] eventsPerStream,
boolean isNewData)
Returns the sort key for a given row. |
MultiKeyUntyped[] |
getSortKeyPerRow(EventBean[] generatingEvents,
boolean isNewData)
Returns the sort key for a each row where a row is a single event (no join, single stream). |
EventBean[] |
sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents,
boolean isNewData)
Sort the output events. |
EventBean[] |
sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents,
MultiKeyUntyped[] groupByKeys,
boolean isNewData)
Sort the output events, using the provided group-by keys for evaluating grouped aggregation functions, and avoiding the cost of recomputing the keys. |
EventBean[] |
sort(EventBean[] outgoingEvents,
MultiKeyUntyped[] orderKeys)
Sort a given array of outgoing events using the sort keys returning a sorted outgoing event array. |
Method Detail |
---|
EventBean[] sort(EventBean[] outgoingEvents, EventBean[][] generatingEvents, boolean isNewData)
outgoingEvents
- - the events to be sortedgeneratingEvents
- - the events that generated the output events (each event has a corresponding array of generating events per different event streams)isNewData
- - indicates whether we are dealing with new data (istream) or old data (rstream)
EventBean[] sort(EventBean[] outgoingEvents, EventBean[][] generatingEvents, MultiKeyUntyped[] groupByKeys, boolean isNewData)
outgoingEvents
- - the events to sortgeneratingEvents
- - the events that generated the output events (each event has a corresponding array of generating events per different event streams)groupByKeys
- - the keys to use for determining the group-by group of output eventsisNewData
- - indicates whether we are dealing with new data (istream) or old data (rstream)
MultiKeyUntyped getSortKey(EventBean[] eventsPerStream, boolean isNewData)
eventsPerStream
- is the row consisting of one event per streamisNewData
- is true for new data
MultiKeyUntyped[] getSortKeyPerRow(EventBean[] generatingEvents, boolean isNewData)
generatingEvents
- is the rows consisting of one event per rowisNewData
- is true for new data
EventBean[] sort(EventBean[] outgoingEvents, MultiKeyUntyped[] orderKeys)
outgoingEvents
- is the events to sortorderKeys
- is the keys to sort by
|
© 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 |