Modifier and Type | Method and Description |
---|---|
BulkFormat.RecordIterator<T> |
StreamFormatAdapter.Reader.readBatch() |
BulkFormat.RecordIterator<T> |
FileRecordFormatAdapter.Reader.readBatch() |
Modifier and Type | Method and Description |
---|---|
static <T> FileRecords<T> |
FileRecords.forRecords(String splitId,
BulkFormat.RecordIterator<T> recordsForSplit) |
Modifier and Type | Method and Description |
---|---|
BulkFormat.RecordIterator<T> |
BulkFormat.Reader.readBatch()
Reads one batch.
|
Modifier and Type | Class and Description |
---|---|
class |
ArrayResultIterator<E>
A simple
BulkFormat.RecordIterator that returns the elements of an array, one after the
other. |
class |
IteratorResultIterator<E>
A simple
BulkFormat.RecordIterator that returns the elements of an iterator, augmented
with position information. |
class |
RecyclableIterator<E>
Utility base class for iterators that accept a recycler.
|
class |
SingletonResultIterator<E>
A simple
BulkFormat.RecordIterator that returns a single value. |
Modifier and Type | Method and Description |
---|---|
abstract BulkFormat.RecordIterator<T> |
ParquetVectorizedInputFormat.ParquetReaderBatch.convertAndGetIterator(long rowsReturned)
Provides reading iterator after the records are written to the
ParquetVectorizedInputFormat.ParquetReaderBatch.columnarBatch . |
Modifier and Type | Method and Description |
---|---|
abstract BulkFormat.RecordIterator<T> |
AbstractOrcFileInputFormat.OrcReaderBatch.convertAndGetIterator(OrcVectorizedBatchWrapper<BatchT> orcVectorizedRowBatch,
long startingOffset)
Converts the ORC VectorizedRowBatch into the result structure and returns an iterator
over the entries.
|
BulkFormat.RecordIterator<T> |
AbstractOrcFileInputFormat.OrcVectorizedReader.readBatch() |
Modifier and Type | Class and Description |
---|---|
class |
ColumnarRowIterator
A
BulkFormat.RecordIterator that returns RowData s. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.