com.espertech.esper.common.internal.epl.join.queryplan

Class HistoricalDataPlanNodeForge

java.lang.Object

com.espertech.esper.common.internal.epl.join.queryplan.QueryPlanNodeForge

com.espertech.esper.common.internal.epl.join.queryplan.HistoricalDataPlanNodeForge

All Implemented Interfaces:

CodegenMakeable<SAIFFInitializeSymbol>

public class HistoricalDataPlanNodeForge
extends QueryPlanNodeForge

Query plan for performing a historical data lookup.

Translates into a particular execution for use in regular and outer joins.

Constructor Summary

Constructors

Constructor and Description
HistoricalDataPlanNodeForge(int streamNum, int rootStreamNum, int lookupStreamNum, int numStreams, ExprForge outerJoinExprEval) Ctor.

Method Summary

Modifier and Type	Method and Description
void	accept(QueryPlanNodeForgeVisitor visitor)
void	addIndexes(HashSet<TableLookupIndexReqKey> usedIndexes)
int	getLookupStreamNum()
int	getNumStreams()
int	getRootStreamNum()
int	getStreamNum()
CodegenExpression	make(CodegenMethodScope parent, SAIFFInitializeSymbol symbols, CodegenClassScope classScope)
protected void	print(IndentWriter writer) Print a long readable format of the query node to the supplied PrintWriter.
void	setHistoricalIndexLookupStrategy(HistoricalIndexLookupStrategyForge historicalIndexLookupStrategy)
void	setPollResultIndexingStrategy(PollResultIndexingStrategyForge pollResultIndexingStrategy)

Methods inherited from class com.espertech.esper.common.internal.epl.join.queryplan.QueryPlanNodeForge

print

Methods inherited from class java.lang.Object

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

Constructor Detail

HistoricalDataPlanNodeForge

public HistoricalDataPlanNodeForge(int streamNum,
                                   int rootStreamNum,
                                   int lookupStreamNum,
                                   int numStreams,
                                   ExprForge outerJoinExprEval)

Ctor.

Parameters:

streamNum - the historical stream num

rootStreamNum - the stream number of the query plan providing incoming events

lookupStreamNum - the stream that provides polling/lookup events

numStreams - number of streams in join

outerJoinExprEval - outer join expression node or null if none defined

Method Detail

addIndexes

public void addIndexes(HashSet<TableLookupIndexReqKey> usedIndexes)

Specified by:

addIndexes in class QueryPlanNodeForge

make

public CodegenExpression make(CodegenMethodScope parent,
                              SAIFFInitializeSymbol symbols,
                              CodegenClassScope classScope)

setPollResultIndexingStrategy

public void setPollResultIndexingStrategy(PollResultIndexingStrategyForge pollResultIndexingStrategy)

setHistoricalIndexLookupStrategy

public void setHistoricalIndexLookupStrategy(HistoricalIndexLookupStrategyForge historicalIndexLookupStrategy)

print

protected void print(IndentWriter writer)

Description copied from class: QueryPlanNodeForge

Print a long readable format of the query node to the supplied PrintWriter.

Specified by:

print in class QueryPlanNodeForge

Parameters:

writer - is the indentation writer to print to

getStreamNum

public int getStreamNum()

getRootStreamNum

public int getRootStreamNum()

getLookupStreamNum

public int getLookupStreamNum()

getNumStreams

public int getNumStreams()

accept

public void accept(QueryPlanNodeForgeVisitor visitor)

Specified by:

accept in class QueryPlanNodeForge