risingwave_frontend::stream_fragmenter

Function build_graph

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