Function get_new_table_plan

async fn get_new_table_plan(
    table_name: String,
    database_id: u32,
    owner: u32,
    cdc_table_change: Option<TableSchemaChange>,
) -> Result<ReplaceJobPlan, RwError>

Rebuild the table’s streaming plan, possibly with cdc column changes.