risingwave_frontend::stream_fragmenter

Function build_graph_with_strategy

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