net.esper.eql.join.exec
Class LookupInstructionExecNode.MyResultAssembler

java.lang.Object
  extended by net.esper.eql.join.exec.LookupInstructionExecNode.MyResultAssembler
All Implemented Interfaces:
ResultAssembler
Enclosing class:
LookupInstructionExecNode

public class LookupInstructionExecNode.MyResultAssembler
extends Object
implements ResultAssembler

Receives result rows posted by result set assembly nodes.


Constructor Summary
LookupInstructionExecNode.MyResultAssembler(int rootStream)
          Ctor.
 
Method Summary
 void result(EventBean[] row, int fromStreamNum, EventBean myEvent, Node myNode)
          Publish a result row.
 void setResult(List<EventBean[]> result, EventBean rootEvent)
          Supplies the result list to which to add result rows.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

LookupInstructionExecNode.MyResultAssembler

public LookupInstructionExecNode.MyResultAssembler(int rootStream)
Ctor.

Parameters:
rootStream - is the root stream for which we get results
Method Detail

setResult

public void setResult(List<EventBean[]> result,
                      EventBean rootEvent)
Supplies the result list to which to add result rows.

Parameters:
result - is the list of rows
rootEvent - is the event for lookup in other streams

result

public void result(EventBean[] row,
                   int fromStreamNum,
                   EventBean myEvent,
                   Node myNode)
Description copied from interface: ResultAssembler
Publish a result row.

Specified by:
result in interface ResultAssembler
Parameters:
row - is the result to publish
fromStreamNum - is the originitor that publishes the row
myEvent - is optional and is the event that led to the row result
myNode - is optional and is the result node of the event that led to the row result