Class PlanExecutionNode
- java.lang.Object
-
- org.teiid.query.processor.relational.RelationalNode
-
- org.teiid.query.processor.relational.SubqueryAwareRelationalNode
-
- org.teiid.query.processor.relational.PlanExecutionNode
-
- All Implemented Interfaces:
Cloneable
,BatchCollector.BatchProducer
- Direct Known Subclasses:
DependentProcedureExecutionNode
,InsertPlanExecutionNode
public class PlanExecutionNode extends SubqueryAwareRelationalNode
-
-
Field Summary
-
Fields inherited from class org.teiid.query.processor.relational.RelationalNode
childCount
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
PlanExecutionNode()
PlanExecutionNode(int nodeID)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Object
clone()
All the implementation of Cloneable interface need to implement clone() method.void
closeDirect()
protected void
copyTo(PlanExecutionNode target)
PlanNode
getDescriptionProperties()
protected void
getNodeString(StringBuffer str)
Collection<? extends LanguageObject>
getObjects()
ProcessorPlan
getProcessorPlan()
protected boolean
hasNextCommand()
TupleBatch
nextBatchDirect()
Template method for subclasses to implement.void
open()
protected boolean
openPlanImmediately()
protected boolean
prepareNextCommand()
Boolean
requiresTransaction(boolean transactionalReads)
void
reset()
void
setProcessorPlan(ProcessorPlan plan)
-
Methods inherited from class org.teiid.query.processor.relational.SubqueryAwareRelationalNode
getEvaluator, requiresTransaction, setReferenceValues
-
Methods inherited from class org.teiid.query.processor.relational.RelationalNode
addBatchRow, addChild, close, copyTo, createLookupMap, getBatchSize, getBuffer, getBufferDirect, getBufferManager, getChildCount, getChildren, getClassName, getConnectionID, getContext, getDataManager, getElements, getEstimateNodeCardinality, getID, getNodeStatistics, getOutputElements, getParent, getProjectionIndexes, hasBuffer, hasPendingRows, initialize, isBatchFull, isClosed, isLastBatch, nextBatch, nodeToString, projectTuple, projectTuple, pullBatch, setContext, setElements, setEstimateDepAccessCardinality, setEstimateDepJoinCost, setEstimateJoinCost, setEstimateNodeCardinality, setEstimateNodeSetSize, setID, setParent, terminateBatches, toString, unwrapException
-
-
-
-
Method Detail
-
reset
public void reset()
- Overrides:
reset
in classSubqueryAwareRelationalNode
-
setProcessorPlan
public void setProcessorPlan(ProcessorPlan plan)
-
open
public void open() throws TeiidComponentException, TeiidProcessingException
- Overrides:
open
in classRelationalNode
- Throws:
TeiidComponentException
TeiidProcessingException
-
openPlanImmediately
protected boolean openPlanImmediately()
-
nextBatchDirect
public TupleBatch nextBatchDirect() throws BlockedException, TeiidComponentException, TeiidProcessingException
Description copied from class:RelationalNode
Template method for subclasses to implement.- Specified by:
nextBatchDirect
in classRelationalNode
- Returns:
- Throws:
BlockedException
TeiidComponentException
TeiidProcessingException
- if exception related to user input occured
-
prepareNextCommand
protected boolean prepareNextCommand() throws BlockedException, TeiidComponentException, TeiidProcessingException
-
hasNextCommand
protected boolean hasNextCommand()
-
closeDirect
public void closeDirect()
- Overrides:
closeDirect
in classSubqueryAwareRelationalNode
-
getNodeString
protected void getNodeString(StringBuffer str)
- Overrides:
getNodeString
in classRelationalNode
-
getProcessorPlan
public ProcessorPlan getProcessorPlan()
-
clone
public Object clone()
Description copied from class:RelationalNode
All the implementation of Cloneable interface need to implement clone() method. The plan is only clonable in the pre-execution stage, not the execution state (things like program state, result sets, etc). It's only safe to call that method in between query processings, in other words, it's only safe to call clone() on a plan after nextTuple() returns null, meaning the plan has finished processing.- Specified by:
clone
in classRelationalNode
-
copyTo
protected void copyTo(PlanExecutionNode target)
-
getDescriptionProperties
public PlanNode getDescriptionProperties()
- Overrides:
getDescriptionProperties
in classRelationalNode
-
requiresTransaction
public Boolean requiresTransaction(boolean transactionalReads)
- Overrides:
requiresTransaction
in classSubqueryAwareRelationalNode
- Returns:
- true if required, false if not required, and null if a single source command is issued and a transaction may be needed.
-
getObjects
public Collection<? extends LanguageObject> getObjects()
- Specified by:
getObjects
in classSubqueryAwareRelationalNode
-
-