pub(crate) type RowGroupReader = RowGroupReaderBase<Arc<FileRangeContext>>;
Expand description
RowGroupReader that reads from [FileRange].
Aliased Type§
struct RowGroupReader {
context: Arc<FileRangeContext>,
reader: ParquetRecordBatchReader,
batches: VecDeque<Batch>,
metrics: ReaderMetrics,
}
Fields§
§context: Arc<FileRangeContext>
Context of RowGroupReader so adapts to different underlying implementation.
reader: ParquetRecordBatchReader
Inner parquet reader.
batches: VecDeque<Batch>
Buffered batches to return.
metrics: ReaderMetrics
Local scan metrics.