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

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

Direct Known Subclasses:

TableLookupExecNodeTableLocking

public class TableLookupExecNode
extends ExecNode

Execution node for lookup in a table.

Field Summary

protected JoinExecTableLookupStrategy

lookupStrategy

Constructor Summary

TableLookupExecNode(int indexedStream, JoinExecTableLookupStrategy lookupStrategy)
Ctor.

Method Summary

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, java.util.Collection<EventBean[]> result, ExprEvaluatorContext exprEvaluatorContext) Process single event using the prefill events to compile lookup results.
protected void	processResults(EventBean[] prefillPath, java.util.Collection<EventBean[]> result, java.util.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

TableLookupExecNode

public TableLookupExecNode(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,
                    java.util.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,
                              java.util.Collection<EventBean[]> result,
                              java.util.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