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

java.lang.Object
  com.espertech.esper.epl.join.plan.LookupInstructionPlan

public class LookupInstructionPlan
extends java.lang.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

LookupInstructionPlan(int fromStream, java.lang.String fromStreamName, int[] toStreams, TableLookupPlan[] lookupPlans, HistoricalDataPlanNode[] historicalPlans, boolean[] requiredPerStream)
Ctor.

Method Summary

void	addIndexes(java.util.HashSet<TableLookupIndexReqKey> usedIndexes)
int	getFromStream()
java.lang.String	getFromStreamName()
HistoricalDataPlanNode[]	getHistoricalPlans()
TableLookupPlan[]	getLookupPlans()
boolean[]	getRequiredPerStream()
int[]	getToStreams()
LookupInstructionExec	makeExec(java.lang.String statementName, java.lang.String statementId, java.lang.annotation.Annotation[] annotations, java.util.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,
                             java.lang.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(java.lang.String statementName,
                                      java.lang.String statementId,
                                      java.lang.annotation.Annotation[] annotations,
                                      java.util.Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
                                      EventType[] streamTypes,
                                      Viewable[] streamViews,
                                      HistoricalStreamIndexList[] historicalStreamIndexLists,
                                      VirtualDWView[] viewExternal)

Constructs the executable from the plan.

Parameters:

statementName -

statementId -

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

print

public void print(IndentWriter writer)

Output the planned instruction.

Parameters:

writer - to output to

addIndexes

public void addIndexes(java.util.HashSet<TableLookupIndexReqKey> usedIndexes)

getFromStream

public int getFromStream()

getFromStreamName

public java.lang.String getFromStreamName()

getToStreams

public int[] getToStreams()

getLookupPlans

public TableLookupPlan[] getLookupPlans()

getRequiredPerStream

public boolean[] getRequiredPerStream()

getHistoricalPlans

public HistoricalDataPlanNode[] getHistoricalPlans()