assign_cdc_table_snapshot_splits_impl

risingwave_meta::stream::cdc

Function assign_cdc_table_snapshot_splits_impl 

Source 
pub(crate) async fn assign_cdc_table_snapshot_splits_impl(
    table_job_id: JobId,
    actor_ids: HashSet<ActorId>,
    meta_store: &SqlMetaStore,
    completed_cdc_job_ids: Option<&HashSet<JobId>>,
) -> MetaResult<CdcTableSnapshotSplitAssignment>