reload_cdc_table_snapshot_splits

risingwave_meta::stream::cdc

Function reload_cdc_table_snapshot_splits 

Source 
pub async fn reload_cdc_table_snapshot_splits(
    txn: &impl ConnectionTrait,
    database_id: Option<DatabaseId>,
) -> MetaResult<HashMap<JobId, CdcTableSnapshotSplits>>