mito2::read::scan_util

Function scan_mem_ranges

Source
pub(crate) fn scan_mem_ranges(
    stream_ctx: Arc<StreamContext>,
    part_metrics: PartitionMetrics,
    index: RowGroupIndex,
    time_range: FileTimeRange,
) -> impl Stream<Item = Result<Batch>>
Expand description

Scans memtable ranges at index.