risingwave_frontend::handler::create_source

Function generate_stream_graph_for_source

Source 
pub(super) fn generate_stream_graph_for_source(
    handler_args: HandlerArgs,
    source_catalog: SourceCatalog,
) -> Result<PbStreamFragmentGraph>