risingwave_frontend::handler::explain_analyze_stream_job::graph

Function extract_stream_node_infos

Source 
pub(super) fn extract_stream_node_infos(
    fragments: Vec<FragmentInfo>,
) -> (u64, HashSet<u32>, HashMap<u64, StreamNode>)
Expand description

Extracts the root node of the plan, as well as the adjacency list