risingwave_meta::stream::cdc

Function assign_cdc_table_snapshot_splits_impl

Source 
pub(crate) async fn assign_cdc_table_snapshot_splits_impl(
    table_id: u32,
    actor_ids: HashSet<u32>,
    meta_store: &SqlMetaStore,
) -> MetaResult<CdcTableSnapshotSplitAssignment>