Package org.teiid.query.processor
Interface BatchCollector.BatchProducer
-
- All Known Implementing Classes:
AccessNode
,ArrayTableNode
,BatchedUpdateNode
,BatchedUpdatePlan
,DdlPlan
,DependentAccessNode
,DependentProcedureAccessNode
,DependentProcedureExecutionNode
,DupRemoveNode
,ExplainProcessPlan
,ForEachRowPlan
,GroupingNode
,InsertPlanExecutionNode
,JoinNode
,LimitNode
,NullNode
,ObjectTableNode
,PlanExecutionNode
,ProcedurePlan
,ProcessorPlan
,ProjectIntoNode
,ProjectNode
,QueryProcessor
,RelationalNode
,RelationalPlan
,SaxonXMLTableNode
,SelectNode
,SortNode
,SourceTriggerActionPlanner.CompositeProcessorPlan
,SubqueryAwareRelationalNode
,TextTableNode
,UnionAllNode
,WindowFunctionProjectNode
- Enclosing class:
- BatchCollector
public static interface BatchCollector.BatchProducer
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
close()
TupleBuffer
getBuffer(int maxRows)
return the final tuple buffer or null if not availableList
getOutputElements()
Get list of resolved elements describing output columns for this plan.boolean
hasBuffer()
TupleBatch
nextBatch()
Get a batch of results or possibly an Exception.
-
-
-
Method Detail
-
nextBatch
TupleBatch nextBatch() throws BlockedException, TeiidComponentException, TeiidProcessingException
Get a batch of results or possibly an Exception.- 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
-
getOutputElements
List getOutputElements()
Get list of resolved elements describing output columns for this plan.- Returns:
- List of SingleElementSymbol
-
getBuffer
TupleBuffer getBuffer(int maxRows) throws BlockedException, TeiidComponentException, TeiidProcessingException
return the final tuple buffer or null if not available- Parameters:
maxRows
-- Returns:
- Throws:
TeiidProcessingException
TeiidComponentException
BlockedException
-
hasBuffer
boolean hasBuffer()
-
close
void close() throws TeiidComponentException
- Throws:
TeiidComponentException
-
-