public class VectorizedTableScanIterable extends CloseableGroup implements CloseableIterable<ColumnarBatch>
ArrowReader
for details.CloseableIterable.ConcatCloseableIterable<E>
Constructor and Description |
---|
VectorizedTableScanIterable(TableScan scan)
Create a new instance using default values for
batchSize and reuseContainers . |
VectorizedTableScanIterable(TableScan scan,
int batchSize,
boolean reuseContainers)
Create a new instance.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Close all the registered resources.
|
CloseableIterator<ColumnarBatch> |
iterator()
Returns a closeable iterator over elements of type
T . |
addCloseable, addCloseable, setSuppressCloseFailure
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
combine, concat, count, empty, filter, filter, transform, whenComplete, withNoopClose, withNoopClose
public VectorizedTableScanIterable(TableScan scan)
batchSize
and reuseContainers
.
The batchSize
is set to BATCH_SIZE_IN_NUM_ROWS
and reuseContainers
is
set to false
.public VectorizedTableScanIterable(TableScan scan, int batchSize, boolean reuseContainers)
See ArrowReader(TableScan, int, boolean)
for details.
public CloseableIterator<ColumnarBatch> iterator()
CloseableIterable
T
.iterator
in interface java.lang.Iterable<ColumnarBatch>
iterator
in interface CloseableIterable<ColumnarBatch>
CloseableIterator
.public void close() throws java.io.IOException
CloseableGroup
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
close
in class CloseableGroup
java.io.IOException