Function build_flat_sources

Source
pub(crate) async fn build_flat_sources(
    stream_ctx: &Arc<StreamContext>,
    part_range: &PartitionRange,
    compaction: bool,
    part_metrics: &PartitionMetrics,
    range_builder_list: Arc<RangeBuilderList>,
    sources: &mut Vec<BoxedRecordBatchStream>,
) -> Result<()>
Expand description

Builds flat sources for the partition range and push them to the sources vector.