risingwave_frontend::handler::alter_table_drop_connector

Function rewrite_table_definition

Source 
fn rewrite_table_definition(
    original_table_def: &Arc<TableCatalog>,
    original_source_def: &Arc<SourceCatalog>,
    original_statement: Statement,
) -> Result<Statement, RwError>