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

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

Direct Known Subclasses:

HistoricalDataPlanNode, LookupInstructionQueryPlanNode, NestedIterationNode, QueryPlanNodeNoOp, TableLookupNode, TableOuterLookupNode

public abstract class QueryPlanNode
extends java.lang.Object

Specification node for a query execution plan to be extended by specific execution specification nodes.

Constructor Summary

QueryPlanNode()

Method Summary

abstract void	addIndexes(java.util.HashSet<TableLookupIndexReqKey> usedIndexes)
abstract ExecNode	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, java.util.concurrent.locks.Lock[] tableSecondaryIndexLocks) Make execution node from this specification.
protected abstract void	print(IndentWriter writer) Print a long readable format of the query node to the supplied PrintWriter.
static java.lang.String	print(QueryPlanNode[] planNodeSpecs) Print in readable format the execution plan spec.

Methods inherited from class java.lang.Object

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

Constructor Detail

QueryPlanNode

public QueryPlanNode()

Method Detail

makeExec

public abstract ExecNode 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,
                                  java.util.concurrent.locks.Lock[] tableSecondaryIndexLocks)

Make execution node from this specification.

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 - @return execution node matching spec

tableSecondaryIndexLocks -

addIndexes

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

print

protected abstract void print(IndentWriter writer)

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

Parameters:

writer - is the indentation writer to print to

print

public static java.lang.String print(QueryPlanNode[] planNodeSpecs)

Print in readable format the execution plan spec.

Parameters:

planNodeSpecs - - plans to print

Returns:

readable text with plans