Function parallel_cdc_table_backfill_fragment 

pub(crate) fn parallel_cdc_table_backfill_fragment<'a>(
    fragments: impl Iterator<Item = &'a Fragment>,
) -> Option<(&'a Fragment, &'a StreamCdcScanNode)>