com.espertech.esper.epl.join.plan

Class LookupInstructionQueryPlanNode

java.lang.Object

com.espertech.esper.epl.join.plan.QueryPlanNode

com.espertech.esper.epl.join.plan.LookupInstructionQueryPlanNode

public class LookupInstructionQueryPlanNode
extends QueryPlanNode

Query plan for executing a set of lookup instructions and assembling an end result via a set of assembly instructions.

Constructor Summary

Constructors

Constructor and Description
LookupInstructionQueryPlanNode(int rootStream, java.lang.String rootStreamName, int numStreams, boolean[] requiredPerStream, java.util.List<LookupInstructionPlan> lookupInstructions, java.util.List<BaseAssemblyNodeFactory> assemblyInstructionFactories) Ctor.

Method Summary

Modifier and Type	Method and Description
void	addIndexes(java.util.HashSet<TableLookupIndexReqKey> usedIndexes)
java.util.List<BaseAssemblyNodeFactory>	getAssemblyInstructionFactories()
java.util.List<LookupInstructionPlan>	getLookupInstructions()
int	getNumStreams()
boolean[]	getRequiredPerStream()
int	getRootStream()
java.lang.String	getRootStreamName()
ExecNode	makeExec(java.lang.String statementName, int statementId, java.lang.annotation.Annotation[] annotations, java.util.Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream, EventType[] streamTypes, Viewable[] streamViews, HistoricalStreamIndexList[] historicalStreamIndexLists, VirtualDWView[] viewExternal, java.util.concurrent.locks.Lock[] tableSecondaryIndexLocks) Make execution node from this specification.
protected void	print(IndentWriter writer) Print a long readable format of the query node to the supplied PrintWriter.

Methods inherited from class com.espertech.esper.epl.join.plan.QueryPlanNode

print

Methods inherited from class java.lang.Object

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

Constructor Detail

LookupInstructionQueryPlanNode

public LookupInstructionQueryPlanNode(int rootStream,
                                      java.lang.String rootStreamName,
                                      int numStreams,
                                      boolean[] requiredPerStream,
                                      java.util.List<LookupInstructionPlan> lookupInstructions,
                                      java.util.List<BaseAssemblyNodeFactory> assemblyInstructionFactories)

Ctor.

Parameters:

rootStream - is the stream supplying the lookup event

rootStreamName - is the name of the stream supplying the lookup event

numStreams - is the number of streams

lookupInstructions - is a list of lookups to perform

requiredPerStream - indicates which streams are required and which are optional in the lookup

assemblyInstructionFactories - is the bottom-up assembly factory nodes to assemble a lookup result nodes

Method Detail

makeExec

public ExecNode makeExec(java.lang.String statementName,
                         int statementId,
                         java.lang.annotation.Annotation[] annotations,
                         java.util.Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
                         EventType[] streamTypes,
                         Viewable[] streamViews,
                         HistoricalStreamIndexList[] historicalStreamIndexLists,
                         VirtualDWView[] viewExternal,
                         java.util.concurrent.locks.Lock[] tableSecondaryIndexLocks)

Description copied from class: QueryPlanNode

Make execution node from this specification.

Specified by:

makeExec in class QueryPlanNode

Parameters:

statementName - statement name

statementId - statement id

annotations - annotations

indexesPerStream - - tables build for each stream

streamTypes - - event type of each stream

streamViews - - viewable per stream for access to historical data

historicalStreamIndexLists - index management for historical streams

viewExternal - view

tableSecondaryIndexLocks - locks

Returns:

execution node matching spec

addIndexes

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

Specified by:

addIndexes in class QueryPlanNode

print

protected void print(IndentWriter writer)

Description copied from class: QueryPlanNode

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

Specified by:

print in class QueryPlanNode

Parameters:

writer - is the indentation writer to print to

getRootStream

public int getRootStream()

getRootStreamName

public java.lang.String getRootStreamName()

getNumStreams

public int getNumStreams()

getLookupInstructions

public java.util.List<LookupInstructionPlan> getLookupInstructions()

getRequiredPerStream

public boolean[] getRequiredPerStream()

getAssemblyInstructionFactories

public java.util.List<BaseAssemblyNodeFactory> getAssemblyInstructionFactories()