Package org.teiid.query.optimizer
Class SourceTriggerActionPlanner.CompositeProcessorPlan
- java.lang.Object
-
- org.teiid.query.processor.ProcessorPlan
-
- org.teiid.query.optimizer.SourceTriggerActionPlanner.CompositeProcessorPlan
-
- All Implemented Interfaces:
Cloneable
,BatchCollector.BatchProducer
- Enclosing class:
- SourceTriggerActionPlanner
public static class SourceTriggerActionPlanner.CompositeProcessorPlan extends ProcessorPlan
TODO: elevate the transaction handling?
-
-
Constructor Summary
Constructors Constructor Description CompositeProcessorPlan(List<ProcessorPlan> plans, List<String> names, Table t)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ProcessorPlan
clone()
Return a safe clone of the ProcessorPlan.void
close()
Close the plan after processing.List
getOutputElements()
Get list of resolved elements describing output columns for this plan.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.-
Methods inherited from class org.teiid.query.processor.ProcessorPlan
addWarning, getBuffer, getContext, getDescriptionProperties, hasBuffer, requiresTransaction, reset, setContext
-
-
-
-
Constructor Detail
-
CompositeProcessorPlan
public CompositeProcessorPlan(List<ProcessorPlan> plans, List<String> names, Table t)
-
-
Method Detail
-
getOutputElements
public List getOutputElements()
Description copied from class:ProcessorPlan
Get list of resolved elements describing output columns for this plan.- Specified by:
getOutputElements
in interfaceBatchCollector.BatchProducer
- Specified by:
getOutputElements
in classProcessorPlan
- Returns:
- List of SingleElementSymbol
-
open
public void open() throws TeiidComponentException, TeiidProcessingException
Description copied from class:ProcessorPlan
Open the plan for processing.- Specified by:
open
in classProcessorPlan
- Throws:
TeiidComponentException
TeiidProcessingException
-
initialize
public void initialize(CommandContext context, ProcessorDataManager dataMgr, BufferManager bufferMgr)
Description copied from class:ProcessorPlan
Initialize the plan with some required pieces of data for making queries. The data manager is used to make queries and the processorID must be passed with the request so the data manager can find the processor again.- Overrides:
initialize
in classProcessorPlan
- Parameters:
context
- Process execution contextdataMgr
- Data manager referencebufferMgr
- Buffer manager reference
-
nextBatch
public TupleBatch nextBatch() throws BlockedException, TeiidComponentException, TeiidProcessingException
Description copied from class:ProcessorPlan
Get a batch of results or possibly an Exception.- Specified by:
nextBatch
in interfaceBatchCollector.BatchProducer
- Specified by:
nextBatch
in classProcessorPlan
- Returns:
- Batch of results
- Throws:
BlockedException
- indicating next batch is not available yetTeiidComponentException
- for non-business rule exceptionTeiidProcessingException
- for business rule exception, related to user input or modeling
-
close
public void close() throws TeiidComponentException
Description copied from class:ProcessorPlan
Close the plan after processing.- Specified by:
close
in interfaceBatchCollector.BatchProducer
- Specified by:
close
in classProcessorPlan
- Throws:
TeiidComponentException
-
clone
public ProcessorPlan clone()
Description copied from class:ProcessorPlan
Return a safe clone of the ProcessorPlan. A ProcessorPlan may only be safely cloned in between processings. That is, it is only safe to clone a plan before it isopened
or after it isclosed
.- Specified by:
clone
in classProcessorPlan
- Returns:
- safe clone of this ProcessorPlan, as long as it is not open for processing
-
-