collect_creating_job_commit_epoch_info

risingwave_meta::barrier::utils

Function collect_creating_job_commit_epoch_info 

Source 
pub(super) fn collect_creating_job_commit_epoch_info(
    commit_info: &mut CommitEpochInfo,
    epoch: u64,
    resps: Vec<BarrierCompleteResponse>,
    barrier_info: &PartialGraphBarrierInfo,
)