snuyanzin commented on code in PR #27488:
URL: https://github.com/apache/flink/pull/27488#discussion_r2740386006
##########
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/MaterializedTableUtils.java:
##########
@@ -115,6 +123,134 @@ public static RefreshMode
fromLogicalRefreshModeToRefreshMode(
}
}
+ // Used to build changes introduced by changed query like
+ // ALTER MATERIALIZED TABLE ... AS ...
+ public static List<TableChange> buildSchemaTableChanges(
Review Comment:
generation of table change based on query change
In case of table schema changes the generation is happening at
`SchemaConverter`
The reason why it is not used here is that `SchemaConverter` works with AST
objects
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
