pub(crate) type MemtableRowGroupReader = RowGroupReaderBase<Arc<BulkIterContext>>;
Aliased Type§
struct MemtableRowGroupReader {
context: Arc<BulkIterContext>,
reader: ParquetRecordBatchReader,
batches: VecDeque<Batch>,
metrics: ReaderMetrics,
}
Fields§
§context: Arc<BulkIterContext>
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.