org.teiid.query.processor

Class BatchCollector.BatchProducerTupleSource

java.lang.Object

org.teiid.query.processor.BatchCollector.BatchProducerTupleSource

All Implemented Interfaces:

TupleSource

Enclosing class:

BatchCollector

public static class BatchCollector.BatchProducerTupleSource
extends Object
implements TupleSource

Constructor Summary

Constructors

Constructor and Description
BatchProducerTupleSource(BatchCollector.BatchProducer sourceNode)
BatchProducerTupleSource(BatchCollector.BatchProducer sourceNode, long startRow)

Method Summary

Modifier and Type	Method and Description
void	closeSource() Closes the Tuple Source.
List<Object>	nextTuple() Returns the next tuple
protected List<?>	updateTuple(List<?> tuple)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BatchProducerTupleSource

public BatchProducerTupleSource(BatchCollector.BatchProducer sourceNode)

BatchProducerTupleSource

public BatchProducerTupleSource(BatchCollector.BatchProducer sourceNode,
                                long startRow)

Method Detail

nextTuple

public List<Object> nextTuple()
                       throws TeiidComponentException,
                              TeiidProcessingException

Description copied from interface: TupleSource

Returns the next tuple

Specified by:

nextTuple in interface TupleSource

Returns:

the next tuple (a List object), or null if there are no more tuples.

Throws:

TeiidComponentException - indicating a non-business exception such as a communication exception, or other such nondeterministic exception

TeiidProcessingException

updateTuple

protected List<?> updateTuple(List<?> tuple)
                       throws ExpressionEvaluationException,
                              BlockedException,
                              TeiidComponentException

Throws:

ExpressionEvaluationException

BlockedException

TeiidComponentException

closeSource

public void closeSource()

Description copied from interface: TupleSource

Closes the Tuple Source.

Specified by:

closeSource in interface TupleSource