com.espertech.esper.epl.join.plan

Class LookupInstructionPlan

java.lang.Object

com.espertech.esper.epl.join.plan.LookupInstructionPlan

public class LookupInstructionPlan
extends Object

Plan for lookup using a from-stream event looking up one or more to-streams using a specified lookup plan for each to-stream.

Constructor Summary

Constructors

Constructor and Description
LookupInstructionPlan(int fromStream, String fromStreamName, int[] toStreams, TableLookupPlan[] lookupPlans, HistoricalDataPlanNode[] historicalPlans, boolean[] requiredPerStream) Ctor.

Method Summary

Modifier and Type	Method and Description
void	addIndexes(HashSet<TableLookupIndexReqKey> usedIndexes)
int	getFromStream()
String	getFromStreamName()
HistoricalDataPlanNode[]	getHistoricalPlans()
TableLookupPlan[]	getLookupPlans()
boolean[]	getRequiredPerStream()
int[]	getToStreams()
LookupInstructionExec	makeExec(String statementName, int statementId, Annotation[] annotations, Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream, EventType[] streamTypes, Viewable[] streamViews, HistoricalStreamIndexList[] historicalStreamIndexLists, VirtualDWView[] viewExternal) Constructs the executable from the plan.
void	print(IndentWriter writer) Output the planned instruction.

Methods inherited from class java.lang.Object

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

Constructor Detail

LookupInstructionPlan

public LookupInstructionPlan(int fromStream,
                             String fromStreamName,
                             int[] toStreams,
                             TableLookupPlan[] lookupPlans,
                             HistoricalDataPlanNode[] historicalPlans,
                             boolean[] requiredPerStream)

Ctor.

Parameters:

fromStream - - the stream supplying the lookup event

fromStreamName - - the stream name supplying the lookup event

toStreams - - the set of streams to look up in

lookupPlans - - the plan to use for each stream to look up in

requiredPerStream - - indicates which of the lookup streams are required to build a result and which are not

historicalPlans - - plans for use with historical streams

Method Detail

makeExec

public LookupInstructionExec makeExec(String statementName,
                                      int statementId,
                                      Annotation[] annotations,
                                      Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
                                      EventType[] streamTypes,
                                      Viewable[] streamViews,
                                      HistoricalStreamIndexList[] historicalStreamIndexLists,
                                      VirtualDWView[] viewExternal)

Constructs the executable from the plan.

Parameters:

statementName - statement name

statementId - statement id

annotations - annotations

indexesPerStream - is the index objects for use in lookups

streamTypes - is the types of each stream

streamViews - the viewable representing each stream

historicalStreamIndexLists - index management for historical streams @return executable instruction

viewExternal - virtual data window

Returns:

instruction exec

print

public void print(IndentWriter writer)

Output the planned instruction.

Parameters:

writer - to output to

addIndexes

public void addIndexes(HashSet<TableLookupIndexReqKey> usedIndexes)

getFromStream

public int getFromStream()

getFromStreamName

public String getFromStreamName()

getToStreams

public int[] getToStreams()

getLookupPlans

public TableLookupPlan[] getLookupPlans()

getRequiredPerStream

public boolean[] getRequiredPerStream()

getHistoricalPlans

public HistoricalDataPlanNode[] getHistoricalPlans()