resolve_source_fragments

risingwave_meta::controller::scale

Function resolve_source_fragments 

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