net.esper.eql.core
Interface ResultSetProcessor

All Known Implementing Classes:
ResultSetProcessorAggregateAll, ResultSetProcessorAggregateGrouped, ResultSetProcessorRowForAll, ResultSetProcessorRowPerGroup, ResultSetProcessorSimple

public interface ResultSetProcessor

Processor for result sets coming from 2 sources. First, out of a simple view (on join). And second, out of a join of event streams. The processor must apply the select-clause, grou-by-clause and having-clauses as supplied. It must state what the event type of the result rows is.


Method Summary
 EventType getResultEventType()
          Returns the event type of processed results.
 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).
 

Method Detail

getResultEventType

EventType getResultEventType()
Returns the event type of processed results.

Returns:
event type of the resulting events posted by the processor.

processViewResult

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). Processes according to select-clauses, group-by clauses and having-clauses and returns new events and old events as specified.

Parameters:
newData - - new events posted by view
oldData - - old events posted by view
Returns:
pair of new events and old events

processJoinResult

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). Processes according to select-clauses, group-by clauses and having-clauses and returns new events and old events as specified.

Parameters:
newEvents - - new events posted by join
oldEvents - - old events posted by join
Returns:
pair of new events and old events