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

Class ExecNode

java.lang.Object

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

Direct Known Subclasses:

ExecNodeAllUnidirectionalOuter, ExecNodeNoOp, HistoricalDataExecNode, LookupInstructionExecNode, NestedIterationExecNode, TableLookupExecNode, TableOuterLookupExecNode

public abstract class ExecNode
extends Object

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

Constructor Summary

Constructors

Constructor and Description
ExecNode()

Method Summary

Modifier and Type	Method and Description
static 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, 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,
                             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 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