public class RelationalPlan extends ProcessorPlan
Constructor and Description |
---|
RelationalPlan(RelationalNode node)
Constructor for RelationalPlan.
|
Modifier and Type | Method and Description |
---|---|
RelationalPlan |
clone()
Return a safe clone of the ProcessorPlan.
|
void |
close()
Close the plan after processing.
|
TupleBuffer |
getBuffer(int maxRows)
return the final tuple buffer or null if not available
|
PlanNode |
getDescriptionProperties() |
List<? extends Expression> |
getOutputElements()
Get list of resolved elements describing output columns for this plan.
|
RelationalNode |
getRootNode() |
boolean |
hasBuffer()
Return true if the plan provides a final buffer via getBuffer
|
void |
initialize(CommandContext context,
ProcessorDataManager dataMgr,
BufferManager bufferMgr)
Initialize the plan with some required pieces of data for making
queries.
|
TupleBatch |
nextBatch()
Get a batch of results or possibly an Exception.
|
void |
open()
Open the plan for processing.
|
Boolean |
requiresTransaction(boolean transactionalReads) |
void |
reset()
Reset a plan so that it can be processed again.
|
void |
setOutputElements(List<? extends Expression> outputCols) |
void |
setRootNode(RelationalNode root) |
void |
setWith(List<WithQueryCommand> with) |
String |
toString() |
addWarning, getContext, setContext
public RelationalPlan(RelationalNode node)
public RelationalNode getRootNode()
public void setRootNode(RelationalNode root)
public void setWith(List<WithQueryCommand> with)
public void initialize(CommandContext context, ProcessorDataManager dataMgr, BufferManager bufferMgr)
ProcessorPlan
initialize
in class ProcessorPlan
context
- Process execution contextdataMgr
- Data manager referencebufferMgr
- Buffer manager referenceProcessorPlan#connectDataManager(ProcessorDataManager)
public List<? extends Expression> getOutputElements()
getOutputElements
in interface BatchCollector.BatchProducer
getOutputElements
in class ProcessorPlan
public void open() throws TeiidComponentException, TeiidProcessingException
ProcessorPlan
open
in class ProcessorPlan
TeiidComponentException
TeiidProcessingException
public TupleBatch nextBatch() throws BlockedException, TeiidComponentException, TeiidProcessingException
ProcessorPlan
nextBatch
in interface BatchCollector.BatchProducer
nextBatch
in class ProcessorPlan
BlockedException
- indicating next batch is not available yetTeiidComponentException
- for non-business rule exceptionTeiidProcessingException
- for business rule exception, related
to user input or modelingProcessorPlan.nextBatch()
public void close() throws TeiidComponentException
ProcessorPlan
close
in interface BatchCollector.BatchProducer
close
in class ProcessorPlan
TeiidComponentException
public void reset()
ProcessorPlan
reset
in class ProcessorPlan
ProcessorPlan.reset()
public RelationalPlan clone()
ProcessorPlan
opened
or after it is closed
.clone
in class ProcessorPlan
public PlanNode getDescriptionProperties()
getDescriptionProperties
in class ProcessorPlan
public void setOutputElements(List<? extends Expression> outputCols)
outputCols
- The outputCols to set.public Boolean requiresTransaction(boolean transactionalReads)
requiresTransaction
in class ProcessorPlan
public TupleBuffer getBuffer(int maxRows) throws BlockedException, TeiidComponentException, TeiidProcessingException
ProcessorPlan
getBuffer
in interface BatchCollector.BatchProducer
getBuffer
in class ProcessorPlan
BlockedException
TeiidComponentException
TeiidProcessingException
public boolean hasBuffer()
ProcessorPlan
hasBuffer
in interface BatchCollector.BatchProducer
hasBuffer
in class ProcessorPlan
Copyright © 2018 JBoss by Red Hat. All rights reserved.