Package org.teiid.query.processor.relational

Class AccessNode

java.lang.Object

org.teiid.query.processor.relational.RelationalNode

org.teiid.query.processor.relational.SubqueryAwareRelationalNode

org.teiid.query.processor.relational.AccessNode

All Implemented Interfaces:

Cloneable, BatchCollector.BatchProducer

Direct Known Subclasses:

DependentAccessNode, DependentProcedureAccessNode

public class AccessNode
extends SubqueryAwareRelationalNode

Field Summary

Fields

Modifier and Type	Field	Description
RegisterRequestParameter.SharedAccessInfo	info
protected Command	nextCommand

Fields inherited from class org.teiid.query.processor.relational.RelationalNode

childCount

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AccessNode()
	AccessNode(int nodeID)

Method Summary

Modifier and Type	Method	Description
protected void	addBatchRow(List<?> row)
Object	clone()	All the implementation of Cloneable interface need to implement clone() method.
void	closeDirect()
protected void	copyTo(AccessNode target)
Command	getCommand()
Set<Object>	getConformedTo()
Expression	getConnectorBindingExpression()
String	getConnectorBindingId()
PlanNode	getDescriptionProperties()
Object	getModelId()
String	getModelName()
protected void	getNodeString(StringBuffer str)
Collection<? extends SubqueryContainer<?>>	getObjects()
List<Expression>	getOriginalSelect()
Object[]	getProjection()
Map<GroupSymbol,RelationalPlan>	getSubPlans()
protected boolean	hasNextCommand()
void	initialize(CommandContext context, BufferManager bufferManager, ProcessorDataManager dataMgr)
boolean	isShouldEvaluate()
void	minimizeProject(Command atomicCommand)
TupleBatch	nextBatchDirect()	Template method for subclasses to implement.
protected Command	nextCommand()
void	open()
protected boolean	prepareNextCommand(Command atomicCommand)
protected boolean	processCommandsIndividually()
Boolean	requiresTransaction(boolean transactionalReads)
void	reset()
void	setCommand(Command command)
void	setConformedTo(Set<Object> conformedTo)
void	setConnectorBindingExpression(Expression connectorBindingExpression)
void	setConnectorBindingId(String connectorBindingId)
void	setModelId(Object id)
void	setModelName(String name)
void	setMultiSource(boolean ex)
void	setShouldEvaluateExpressions(boolean shouldEvaluate)
void	setSubPlans(Map<GroupSymbol,RelationalPlan> plans)
void	setTransactionSupport(ExecutionFactory.TransactionSupport transactionSupport)

Methods inherited from class org.teiid.query.processor.relational.SubqueryAwareRelationalNode

getEvaluator, requiresTransaction, setReferenceValues

Methods inherited from class org.teiid.query.processor.relational.RelationalNode

addChild, close, copyTo, createLookupMap, getBatchSize, getBuffer, getBufferDirect, getBufferManager, getChildCount, getChildren, getClassName, getConnectionID, getContext, getDataManager, getElements, getEstimateNodeCardinality, getID, getNodeStatistics, getOutputElements, getParent, getProjectionIndexes, hasBuffer, hasPendingRows, isBatchFull, isClosed, isLastBatch, nextBatch, nodeToString, projectTuple, projectTuple, pullBatch, setContext, setElements, setEstimateDepAccessCardinality, setEstimateDepJoinCost, setEstimateJoinCost, setEstimateNodeCardinality, setEstimateNodeSetSize, setID, setParent, terminateBatches, toString, unwrapException

Methods inherited from class java.lang.Object

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

Field Detail

nextCommand

protected Command nextCommand

info

public RegisterRequestParameter.SharedAccessInfo info

Constructor Detail

AccessNode

protected AccessNode()

AccessNode

public AccessNode(int nodeID)

Method Detail

initialize

public void initialize(CommandContext context,
                       BufferManager bufferManager,
                       ProcessorDataManager dataMgr)

Overrides:

initialize in class RelationalNode

reset

public void reset()

Overrides:

reset in class SubqueryAwareRelationalNode

setCommand

public void setCommand(Command command)

getCommand

public Command getCommand()

setModelId

public void setModelId(Object id)

getModelId

public Object getModelId()

setModelName

public void setModelName(String name)

getModelName

public String getModelName()

setShouldEvaluateExpressions

public void setShouldEvaluateExpressions(boolean shouldEvaluate)

open

public void open()
          throws TeiidComponentException,
                 TeiidProcessingException

Overrides:

open in class RelationalNode

Throws:

TeiidComponentException

TeiidProcessingException

isShouldEvaluate

public boolean isShouldEvaluate()

minimizeProject

public void minimizeProject(Command atomicCommand)

getOriginalSelect

public List<Expression> getOriginalSelect()

getProjection

public Object[] getProjection()

nextCommand

protected Command nextCommand()
                       throws TeiidProcessingException,
                              TeiidComponentException

Throws:

TeiidProcessingException

TeiidComponentException

prepareNextCommand

protected boolean prepareNextCommand(Command atomicCommand)
                              throws TeiidComponentException,
                                     TeiidProcessingException

Throws:

TeiidComponentException

TeiidProcessingException

nextBatchDirect

public TupleBatch nextBatchDirect()
                           throws BlockedException,
                                  TeiidComponentException,
                                  TeiidProcessingException

Description copied from class: RelationalNode

Template method for subclasses to implement.

Specified by:

nextBatchDirect in class RelationalNode

Returns:

Throws:

BlockedException

TeiidComponentException

TeiidProcessingException - if exception related to user input occured

addBatchRow

protected void addBatchRow(List<?> row)

Overrides:

addBatchRow in class RelationalNode

processCommandsIndividually

protected boolean processCommandsIndividually()

hasNextCommand

protected boolean hasNextCommand()

closeDirect

public void closeDirect()

Overrides:

closeDirect in class SubqueryAwareRelationalNode

getNodeString

protected void getNodeString(StringBuffer str)

Overrides:

getNodeString in class RelationalNode

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 class RelationalNode

copyTo

protected void copyTo(AccessNode target)

getDescriptionProperties

public PlanNode getDescriptionProperties()

Overrides:

getDescriptionProperties in class RelationalNode

getConnectorBindingId

public String getConnectorBindingId()

setConnectorBindingId

public void setConnectorBindingId(String connectorBindingId)

getConnectorBindingExpression

public Expression getConnectorBindingExpression()

setConnectorBindingExpression

public void setConnectorBindingExpression(Expression connectorBindingExpression)

getObjects

public Collection<? extends SubqueryContainer<?>> getObjects()

Specified by:

getObjects in class SubqueryAwareRelationalNode

requiresTransaction

public Boolean requiresTransaction(boolean transactionalReads)

Overrides:

requiresTransaction in class SubqueryAwareRelationalNode

Returns:

true if required, false if not required, and null if a single source command is issued and a transaction may be needed.

setMultiSource

public void setMultiSource(boolean ex)

setSubPlans

public void setSubPlans(Map<GroupSymbol,RelationalPlan> plans)

getSubPlans

public Map<GroupSymbol,RelationalPlan> getSubPlans()

getConformedTo

public Set<Object> getConformedTo()

setConformedTo

public void setConformedTo(Set<Object> conformedTo)

setTransactionSupport

public void setTransactionSupport(ExecutionFactory.TransactionSupport transactionSupport)