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

java.lang.Object
  com.espertech.esper.epl.join.exec.base.ExecNode

Direct Known Subclasses:

ExecNodeNoOp, HistoricalDataExecNode, LookupInstructionExecNode, NestedIterationExecNode, TableLookupExecNode, TableOuterLookupExecNode

public abstract class ExecNode
extends java.lang.Object

Interface for an execution node that looks up events and builds a result set contributing to an overall join result set.

Constructor Summary

ExecNode()

Method Summary

static java.lang.String	print(ExecNode execNode) Print in readable format the execution strategy.
abstract void	print(IndentWriter writer) Output the execution strategy.
abstract void	process(EventBean lookupEvent, EventBean[] prefillPath, java.util.Collection<EventBean[]> result, ExprEvaluatorContext exprEvaluatorContext) Process single event using the prefill events to compile lookup results.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ExecNode

public ExecNode()

Method Detail

process

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

Process single event using the prefill events to compile lookup results.

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

exprEvaluatorContext - context for expression evaluation

print

public abstract void print(IndentWriter writer)

Output the execution strategy.

Parameters:

writer - to output to

print

public static java.lang.String print(ExecNode execNode)

Print in readable format the execution strategy.

Parameters:

execNode - - execution node to print

Returns:

readable text with execution nodes constructed for actual streams