collect_fragment_progress_from_actors

risingwave_meta::barrier::progress

Function collect_fragment_progress_from_actors 

Source 
pub(crate) fn collect_fragment_progress_from_actors(
    job_id: JobId,
    fragment_infos: &HashMap<FragmentId, InflightFragmentInfo>,
    actor_progresses: &[ActorBackfillProgress],
) -> Vec<FragmentBackfillProgress>