Function generate_fragment_graph

fn generate_fragment_graph(
    state: &mut BuildFragmentGraphState,
    stream_node: StreamNode,
) -> Result<()>

Generate fragment DAG from input streaming plan by their dependency.