com.espertech.esper.epl.join.exec
Class LookupInstructionExecNode

java.lang.Object
  extended by com.espertech.esper.epl.join.exec.ExecNode
      extended by com.espertech.esper.epl.join.exec.LookupInstructionExecNode

public class LookupInstructionExecNode
extends ExecNode

Execution for a set of lookup instructions and for a set of result assemble instructions to perform joins and construct a complex result.


Nested Class Summary
static class LookupInstructionExecNode.MyResultAssembler
          Receives result rows posted by result set assembly nodes.
 
Constructor Summary
LookupInstructionExecNode(int rootStream, String rootStreamName, int numStreams, LookupInstructionExec[] lookupInstructions, boolean[] requiredPerStream, BaseAssemblyNode[] assemblyInstructions)
          Ctor.
 
Method Summary
 void print(IndentWriter writer)
          Output the execution strategy.
 void process(EventBean lookupEvent, EventBean[] prefillPath, List<EventBean[]> result)
          Process single event using the prefill events to compile lookup results.
 
Methods inherited from class com.espertech.esper.epl.join.exec.ExecNode
print
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

LookupInstructionExecNode

public LookupInstructionExecNode(int rootStream,
                                 String rootStreamName,
                                 int numStreams,
                                 LookupInstructionExec[] lookupInstructions,
                                 boolean[] requiredPerStream,
                                 BaseAssemblyNode[] assemblyInstructions)
Ctor.

Parameters:
rootStream - is the stream supplying the lookup event
rootStreamName - is the name of the stream supplying the lookup event
numStreams - is the number of streams
lookupInstructions - is a list of lookups to perform
requiredPerStream - indicates which streams are required and which are optional in the lookup
assemblyInstructions - is the bottom-up assembly nodes to assemble a lookup result nodes
Method Detail

process

public void process(EventBean lookupEvent,
                    EventBean[] prefillPath,
                    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

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

© 2007 EsperTech Inc.
All rights reserved.
Visit us at espertech.com