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

Class HistoricalDataPlanNode

java.lang.Object

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

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

public class HistoricalDataPlanNode
extends QueryPlanNode

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
HistoricalDataPlanNode()

Method Summary

Modifier and Type	Method and Description
void	addIndexes(HashSet<TableLookupIndexReqKey> usedIndexes)
ExecNode	makeExec(AgentInstanceContext agentInstanceContext, Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream, EventType[] streamTypes, Viewable[] streamViews, VirtualDWView[] viewExternal, Lock[] tableSecondaryIndexLocks)
HistoricalTableLookupStrategy	makeOuterJoinStategy(Viewable[] streamViews) Returns the table lookup strategy for use in outer joins.
protected void	print(IndentWriter writer)
void	setIndexingStrategy(PollResultIndexingStrategy indexingStrategy)
void	setLookupStrategy(HistoricalIndexLookupStrategy lookupStrategy)
void	setNumStreams(int numStreams)
void	setOuterJoinExprEval(ExprEvaluator outerJoinExprEval)
void	setRootStreamNum(int rootStreamNum)
void	setStreamNum(int streamNum)

Methods inherited from class java.lang.Object

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

Constructor Detail

HistoricalDataPlanNode

public HistoricalDataPlanNode()

Method Detail

makeExec

public ExecNode makeExec(AgentInstanceContext agentInstanceContext,
                         Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
                         EventType[] streamTypes,
                         Viewable[] streamViews,
                         VirtualDWView[] viewExternal,
                         Lock[] tableSecondaryIndexLocks)

Specified by:

makeExec in class QueryPlanNode

makeOuterJoinStategy

public HistoricalTableLookupStrategy makeOuterJoinStategy(Viewable[] streamViews)

Returns the table lookup strategy for use in outer joins.

Parameters:

streamViews - all views in join

Returns:

strategy

addIndexes

public void addIndexes(HashSet<TableLookupIndexReqKey> usedIndexes)

setStreamNum

public void setStreamNum(int streamNum)

setNumStreams

public void setNumStreams(int numStreams)

setLookupStrategy

public void setLookupStrategy(HistoricalIndexLookupStrategy lookupStrategy)

setIndexingStrategy

public void setIndexingStrategy(PollResultIndexingStrategy indexingStrategy)

setRootStreamNum

public void setRootStreamNum(int rootStreamNum)

setOuterJoinExprEval

public void setOuterJoinExprEval(ExprEvaluator outerJoinExprEval)

print

protected void print(IndentWriter writer)