Package org.teiid.query.processor

Class BatchCollector

java.lang.Object

org.teiid.query.processor.BatchCollector

public class BatchCollector
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	BatchCollector.BatchProducer
static class	BatchCollector.BatchProducerTupleSource

Constructor Summary

Constructors

Constructor	Description
BatchCollector(BatchCollector.BatchProducer sourceNode, BufferManager bm, CommandContext context, boolean forwardOnly)

Method Summary

Modifier and Type	Method	Description
TupleBuffer	collectTuples()
TupleBuffer	collectTuples(boolean singleBatch)
protected void	flushBatchDirect(TupleBatch batch, boolean add)
long	getRowCount()
TupleBuffer	getTupleBuffer()
boolean	isSaveLastRow()
void	setRowLimit(int rowLimit)
void	setSaveLastRow(boolean saveLastRow)

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,
                      BufferManager bm,
                      CommandContext context,
                      boolean forwardOnly)
               throws TeiidComponentException

Throws:

TeiidComponentException

Method Detail

collectTuples

public TupleBuffer collectTuples()
                          throws TeiidComponentException,
                                 TeiidProcessingException

Throws:

TeiidComponentException

TeiidProcessingException

collectTuples

public TupleBuffer collectTuples(boolean singleBatch)
                          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 long getRowCount()

setRowLimit

public void setRowLimit(int rowLimit)

setSaveLastRow

public void setSaveLastRow(boolean saveLastRow)

isSaveLastRow

public boolean isSaveLastRow()