net.esper.eql.join.exec
Class TableOuterLookupExecNode

java.lang.Object
  extended by net.esper.eql.join.exec.ExecNode
      extended by net.esper.eql.join.exec.TableOuterLookupExecNode

public class TableOuterLookupExecNode
extends ExecNode

Execution node for lookup in a table for outer joins. This execution node thus generates rows even if no joined events could be found, the joined table events are set to null if no joined events are found.


Constructor Summary
TableOuterLookupExecNode(int indexedStream, TableLookupStrategy lookupStrategy)
          Ctor.
 
Method Summary
 int getIndexedStream()
          Returns target stream for lookup.
 TableLookupStrategy getLookupStrategy()
          Returns strategy for lookup.
 void print(IndentWriter writer)
          Output the execution strategy.
 void process(EventBean lookupEvent, EventBean[] prefillPath, java.util.List<EventBean[]> result)
          Process single event using the prefill events to compile lookup results.
 
Methods inherited from class net.esper.eql.join.exec.ExecNode
print
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TableOuterLookupExecNode

public TableOuterLookupExecNode(int indexedStream,
                                TableLookupStrategy lookupStrategy)
Ctor.

Parameters:
indexedStream - - stream indexed for lookup
lookupStrategy - - strategy to use for lookup (full table/indexed)
Method Detail

getLookupStrategy

public TableLookupStrategy getLookupStrategy()
Returns strategy for lookup.

Returns:
lookup strategy

process

public void process(EventBean lookupEvent,
                    EventBean[] prefillPath,
                    java.util.List<EventBean[]> result)
Description copied from class: ExecNode
Process single event using the prefill events to compile lookup results.

Specified by:
process in class ExecNode
Parameters:
lookupEvent - - event to look up for or query for
prefillPath - - set of events currently in the example tuple to serve as a prototype for result rows.
result - is the list of tuples to add a result row to

getIndexedStream

public int getIndexedStream()
Returns target stream for lookup.

Returns:
indexed stream

print

public void print(IndentWriter writer)
Description copied from class: ExecNode
Output the execution strategy.

Specified by:
print in class ExecNode
Parameters:
writer - to output to