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

java.lang.Object
  com.espertech.esper.epl.join.exec.base.ExecNode
      com.espertech.esper.epl.join.exec.base.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, java.lang.String rootStreamName, int numStreams, LookupInstructionExec[] lookupInstructions, boolean[] requiredPerStream, java.util.List<BaseAssemblyNodeFactory> assemblyInstructionFactories)
Ctor.

Method Summary

void	print(IndentWriter writer) Output the execution strategy.
void	process(EventBean lookupEvent, EventBean[] prefillPath, java.util.Collection<EventBean[]> resultFinalRows, ExprEvaluatorContext exprEvaluatorContext) Process single event using the prefill events to compile lookup results.

Methods inherited from class com.espertech.esper.epl.join.exec.base.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,
                                 java.lang.String rootStreamName,
                                 int numStreams,
                                 LookupInstructionExec[] lookupInstructions,
                                 boolean[] requiredPerStream,
                                 java.util.List<BaseAssemblyNodeFactory> assemblyInstructionFactories)

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

Method Detail

process

public void process(EventBean lookupEvent,
                    EventBean[] prefillPath,
                    java.util.Collection<EventBean[]> resultFinalRows,
                    ExprEvaluatorContext exprEvaluatorContext)

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.

resultFinalRows - is the list of tuples to add a result row to

exprEvaluatorContext - context for expression evaluation

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