risingwave_frontend::handler

Function get_new_table_definition_for_cdc_table

source 
pub async fn get_new_table_definition_for_cdc_table(
    session: &Arc<SessionImpl>,
    table_name: ObjectName,
    new_columns: &[ColumnCatalog],
) -> Result<(Statement, Arc<TableCatalog>), RwError>
Expand description

Used in auto schema change process