pub async fn get_replace_table_plan(
session: &Arc<SessionImpl>,
table_name: ObjectName,
new_definition: Statement,
old_catalog: &Arc<TableCatalog>,
sql_column_strategy: SqlColumnStrategy,
) -> Result<(Option<Source>, Table, StreamFragmentGraph, ColIndexMapping, TableJobType), RwError>