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

Modifier and Type	Method and Description
void	close()
TupleBuffer	getBuffer(int maxRows) return the final tuple buffer or null if not available
List	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 yet

TeiidComponentException - for non-business rule exception

TeiidProcessingException - 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