This is an automated email from the ASF dual-hosted git repository.
snuyanzin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from e42cdd1efe3 [FLINK-38338][runtime] Introduce the abstraction to
describe a rescale event. (#26981)
new 9bc742d38ee [hotfix][table] Rename `SqlAlterDistribution` to
`SqlAlterTableDistribution` and `SqlAlterMaterializedTableAddDistribution` to
`SqlAlterMaterializedTableDistribution`
new 77b9107221b [FLINK-38756][table] Add support for ALTER MATERIALIZED
TABLE ADD columns in parser
new 512fdb2b125 [FLINK-38756][table] Group and reorder converters in
registration logica
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../src/main/codegen/data/Parser.tdd | 9 +-
.../src/main/codegen/includes/parserImpls.ftl | 44 +++++--
... => SqlAlterMaterializedTableDistribution.java} | 50 +++++--
...qlAlterMaterializedTableModifyDistribution.java | 62 ---------
.../ddl/SqlAlterMaterializedTableSchema.java | 141 ++++++++++++++++++++
.../flink/sql/parser/ddl/SqlAlterTableAdd.java | 2 +-
...ibution.java => SqlAlterTableDistribution.java} | 17 ++-
.../flink/sql/parser/ddl/SqlAlterTableSchema.java | 2 +-
.../flink/sql/parser/FlinkSqlParserImplTest.java | 62 ---------
.../MaterializedTableStatementParserTest.java | 146 +++++++++++++++++++++
.../apache/flink/sql/parser/ValidationMatcher.java | 88 +++++++++++++
.../AbstractAlterMaterializedTableConverter.java | 4 +-
...rMaterializedTableAddDistributionConverter.java | 2 +-
...terializedTableModifyDistributionConverter.java | 2 +-
.../operations/converters/SqlNodeConverters.java | 111 +++++++++-------
.../SqlAlterTableAddDistributionConverter.java | 12 +-
.../SqlAlterTableModifyDistributionConverter.java | 12 +-
17 files changed, 543 insertions(+), 223 deletions(-)
rename
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/{SqlAlterMaterializedTableAddDistribution.java
=> SqlAlterMaterializedTableDistribution.java} (55%)
delete mode 100644
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlAlterMaterializedTableModifyDistribution.java
create mode 100644
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlAlterMaterializedTableSchema.java
rename
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/{SqlAlterDistribution.java
=> SqlAlterTableDistribution.java} (83%)
create mode 100644
flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/ValidationMatcher.java
