Package com.espertech.esper.common.internal.epl.join.exec.base

Class HistoricalDataExecNode

java.lang.Object

com.espertech.esper.common.internal.epl.join.strategy.ExecNode

com.espertech.esper.common.internal.epl.join.exec.base.HistoricalDataExecNode

public class HistoricalDataExecNode
extends ExecNode

Execution node for executing a join or outer join against a historical data source, using an lookup strategy for looking up into cached indexes, and an indexing strategy for indexing poll results for future lookups.

Constructor Summary

Constructors

Constructor	Description
HistoricalDataExecNode(HistoricalEventViewable historicalEventViewable, PollResultIndexingStrategy indexingStrategy, HistoricalIndexLookupStrategy indexLookupStrategy, int numStreams, int historicalStreamNumber)	Ctor.

Method Summary

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

Methods inherited from class com.espertech.esper.common.internal.epl.join.strategy.ExecNode

print

Methods inherited from class java.lang.Object

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

Constructor Details

HistoricalDataExecNode

public HistoricalDataExecNode(HistoricalEventViewable historicalEventViewable,
 PollResultIndexingStrategy indexingStrategy,
 HistoricalIndexLookupStrategy indexLookupStrategy,
 int numStreams,
 int historicalStreamNumber)

Ctor.

Parameters:

historicalEventViewable - the view of the historical

indexingStrategy - the strategy to index poll result for future use

indexLookupStrategy - the strategy to use past indexed results

numStreams - the number of streams in the join

historicalStreamNumber - the stream number of the historical

Method Details

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

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