pub(crate) type RowGroupReader = RowGroupReaderBase<Arc<FileRangeContext>>;Expand description
RowGroupReader that reads from [FileRange].
Aliased Type§
pub(crate) struct RowGroupReader {
context: Arc<FileRangeContext>,
reader: ParquetRecordBatchReader,
batches: VecDeque<Batch>,
metrics: ReaderMetrics,
override_sequence: Option<Arc<dyn Array>>,
}Fields§
§context: Arc<FileRangeContext>Context of RowGroupReader so adapts to different underlying implementation.
reader: ParquetRecordBatchReaderInner parquet reader.
batches: VecDeque<Batch>Buffered batches to return.
metrics: ReaderMetricsLocal scan metrics.
override_sequence: Option<Arc<dyn Array>>Cached sequence array to override sequences.