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

Class TableOuterLookupExecNode

java.lang.Object

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

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

Direct Known Subclasses:

TableOuterLookupExecNodeTableLocking

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.

Field Summary

Fields

Modifier and Type	Field and Description
protected JoinExecTableLookupStrategy	lookupStrategy

Constructor Summary

Constructors

Constructor and Description
TableOuterLookupExecNode(int indexedStream, JoinExecTableLookupStrategy lookupStrategy) Ctor.

Method Summary

Modifier and Type	Method and Description
int	getIndexedStream() Returns target stream for lookup.
JoinExecTableLookupStrategy	getLookupStrategy() Returns strategy for lookup.
void	print(IndentWriter writer) Output the execution strategy.
void	process(EventBean lookupEvent, EventBean[] prefillPath, Collection<EventBean[]> result, ExprEvaluatorContext exprEvaluatorContext) Process single event using the prefill events to compile lookup results.
protected void	processResults(EventBean[] prefillPath, Collection<EventBean[]> result, Set<EventBean> joinedEvents)

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

Field Detail

lookupStrategy

protected JoinExecTableLookupStrategy lookupStrategy

Constructor Detail

TableOuterLookupExecNode

public TableOuterLookupExecNode(int indexedStream,
                                JoinExecTableLookupStrategy lookupStrategy)

Ctor.

Parameters:

indexedStream - - stream indexed for lookup

lookupStrategy - - strategy to use for lookup (full table/indexed)

Method Detail

getLookupStrategy

public JoinExecTableLookupStrategy getLookupStrategy()

Returns strategy for lookup.

Returns:

lookup strategy

process

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

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

exprEvaluatorContext - context for expression evaluation

processResults

protected void processResults(EventBean[] prefillPath,
                              Collection<EventBean[]> result,
                              Set<EventBean> joinedEvents)

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