resolve_source_fragments

risingwave_meta::controller::scale

Function resolve_source_fragments 

Source 
async fn resolve_source_fragments<C>(
    txn: &C,
    job_fragments: &HashMap<JobId, HashMap<FragmentId, LoadedFragment>>,
) -> MetaResult<(HashMap<FragmentId, SourceId>, HashMap<FragmentId, Vec<SplitImpl>>)>
where
    C: ConnectionTrait,