risingwave_meta::stream::cdc

Function assign_cdc_table_snapshot_splits

Source 
pub(crate) async fn assign_cdc_table_snapshot_splits(
    original_table_id: u32,
    job: &StreamJobFragments,
    meta_store: &SqlMetaStore,
) -> MetaResult<CdcTableSnapshotSplitAssignment>