Function assign_cdc_table_snapshot_splits

pub(crate) async fn assign_cdc_table_snapshot_splits(
    table_fragments: impl Iterator<Item = &StreamJobFragments>,
    meta_store: &SqlMetaStore,
) -> MetaResult<CdcTableSnapshotSplitAssignment>