pub(crate) fn scan_flat_mem_ranges(
stream_ctx: Arc<StreamContext>,
part_metrics: PartitionMetrics,
index: RowGroupIndex,
) -> impl Stream<Item = Result<RecordBatch>>Expand description
Scans memtable ranges at index using flat format that returns RecordBatch.