risingwave_frontend::handler::create_table

Function generate_stream_graph_for_replace_table

Source 
pub async fn generate_stream_graph_for_replace_table(
    _session: &Arc<SessionImpl>,
    table_name: ObjectName,
    original_catalog: &Arc<TableCatalog>,
    handler_args: HandlerArgs,
    statement: Statement,
    col_id_gen: ColumnIdGenerator,
    sql_column_strategy: SqlColumnStrategy,
) -> Result<(StreamFragmentGraph, TableCatalog, Option<SourceCatalog>, TableJobType), RwError>