fragment_desc_to_distribution

risingwave_meta_service::stream_service

Function fragment_desc_to_distribution 

Source 
fn fragment_desc_to_distribution(
    fragment_desc: FragmentDesc,
    upstreams: Vec<FragmentId>,
    include_node: bool,
) -> FragmentDistribution