Function build_graph

pub fn build_graph(
    plan_node: StreamPlanRef,
    job_type: Option<GraphJobType>,
) -> Result<StreamFragmentGraph>