async fn get_new_table_plan(
table_id: TableId,
database_id: DatabaseId,
owner: u32,
cdc_table_change: Option<TableSchemaChange>,
) -> Result<ReplaceJobPlan, RwError>Expand description
Rebuild the table’s streaming plan, possibly with cdc column changes.