Skip to main content

load_independent_job_fragments

risingwave_meta::barrier::checkpoint::state

Function load_independent_job_fragments 

Source 
fn load_independent_job_fragments(
    fragments: &StreamJobFragmentsToCreate,
) -> HashMap<FragmentId, LoadedFragment>