Package com.espertech.esper.common.internal.epl.join.queryplanouter

Class LookupInstructionPlan

java.lang.Object

com.espertech.esper.common.internal.epl.join.queryplanouter.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.

Field Summary

Fields

Modifier and Type	Field	Description
static final EPTypeClass	EPTYPE

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	addIndexes(HashSet<TableLookupIndexReqKey> usedIndexes)
int	getFromStream()
String	getFromStreamName()
Object[]	getHistoricalPlans()
TableLookupPlan[]	getLookupPlans()
boolean[]	getRequiredPerStream()
int[]	getToStreams()
LookupInstructionExec	makeExec(AgentInstanceContext agentInstanceContext, Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream, EventType[] streamTypes, Viewable[] streamViews, VirtualDWView[] viewExternal)
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

Field Details

EPTYPE

public static final EPTypeClass EPTYPE

Constructor Details

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 Details

makeExec

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

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 Object[] getHistoricalPlans()