risingwave_meta::barrier::cdc_progress

Function load_cdc_fragment_table_mapping

Source 
async fn load_cdc_fragment_table_mapping(
    meta_store: &SqlMetaStore,
) -> MetaResult<HashMap<u32, u32>>