risingwave_frontend::handler

Function get_new_table_definition_for_cdc_table

Source 
pub async fn get_new_table_definition_for_cdc_table(
    original_catalog: Arc<TableCatalog>,
    new_columns: &[ColumnCatalog],
) -> Result<Statement>
Expand description

Used in auto schema change process