public class ForEachRowPlan extends ProcessorPlan
Constructor and Description |
---|
ForEachRowPlan() |
Modifier and Type | Method and Description |
---|---|
ProcessorPlan |
clone()
Return a safe clone of the ProcessorPlan.
|
void |
close()
Close the plan after processing.
|
List<Expression> |
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.
|
Boolean |
requiresTransaction(boolean transactionalReads) |
void |
reset()
Reset a plan so that it can be processed again.
|
void |
setLookupMap(Map<Expression,Integer> symbolMap) |
void |
setParams(Map<ElementSymbol,Expression> params) |
void |
setQueryPlan(ProcessorPlan queryPlan) |
void |
setRowProcedure(ProcedurePlan rowProcedure) |
void |
setSingleRow(boolean singleRow) |
void |
setTupleSource(TupleSource tupleSource) |
String |
toString() |
addWarning, getBuffer, getContext, getDescriptionProperties, hasBuffer, setContext
public ProcessorPlan clone()
ProcessorPlan
opened
or after it is closed
.clone
in class ProcessorPlan
public void close() throws TeiidComponentException
ProcessorPlan
close
in interface BatchCollector.BatchProducer
close
in class ProcessorPlan
TeiidComponentException
public List<Expression> getOutputElements()
ProcessorPlan
getOutputElements
in interface BatchCollector.BatchProducer
getOutputElements
in class ProcessorPlan
public void initialize(CommandContext context, ProcessorDataManager dataMgr, BufferManager bufferMgr)
ProcessorPlan
initialize
in class ProcessorPlan
context
- Process execution contextdataMgr
- Data manager referencebufferMgr
- Buffer manager referencepublic 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 modelingpublic void open() throws TeiidComponentException, TeiidProcessingException
ProcessorPlan
open
in class ProcessorPlan
TeiidComponentException
TeiidProcessingException
public void setQueryPlan(ProcessorPlan queryPlan)
public void setRowProcedure(ProcedurePlan rowProcedure)
public void setParams(Map<ElementSymbol,Expression> params)
public void setLookupMap(Map<Expression,Integer> symbolMap)
public void reset()
ProcessorPlan
reset
in class ProcessorPlan
public Boolean requiresTransaction(boolean transactionalReads)
requiresTransaction
in class ProcessorPlan
public void setTupleSource(TupleSource tupleSource)
public void setSingleRow(boolean singleRow)
Copyright © 2018 JBoss by Red Hat. All rights reserved.