org.teiid.query.processor
Class BatchCollector

java.lang.Object
  org.teiid.query.processor.BatchCollector

public class BatchCollector
extends java.lang.Object

Nested Class Summary

static interface	BatchCollector.BatchProducer
static class	BatchCollector.BatchProducerTupleSource

Constructor Summary

BatchCollector(BatchCollector.BatchProducer sourceNode, TupleBuffer buffer)

Method Summary

TupleBuffer	collectTuples()
protected void	flushBatchDirect(TupleBatch batch, boolean add)
int	getRowCount()
TupleBuffer	getTupleBuffer()

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchCollector

public BatchCollector(BatchCollector.BatchProducer sourceNode,
                      TupleBuffer buffer)

Method Detail

collectTuples

public TupleBuffer collectTuples()
                          throws TeiidComponentException,
                                 TeiidProcessingException

Throws:

TeiidComponentException

TeiidProcessingException

getTupleBuffer

public TupleBuffer getTupleBuffer()

flushBatchDirect

protected void flushBatchDirect(TupleBatch batch,
                                boolean add)
                         throws TeiidComponentException,
                                TeiidProcessingException

Throws:

TeiidComponentException

TeiidProcessingException

getRowCount

public int getRowCount()