mito2::read::scan_util

Function build_flat_file_range_scan_stream

Source 
pub fn build_flat_file_range_scan_stream(
    _stream_ctx: Arc<StreamContext>,
    part_metrics: PartitionMetrics,
    read_type: &'static str,
    ranges: SmallVec<[FileRange; 2]>,
) -> impl Stream<Item = Result<RecordBatch>>
Expand description

Build the stream of scanning the input FileRanges using flat reader that returns RecordBatch.