This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 9d169038784 [FLINK-35164][table] Support `ALTER CATALOG RESET` syntax
add d0f9bb40a61 [FLINK-34172] Add support for altering a distribution via
ALTER TABLE
No new revisions were added by this update.
Summary of changes:
.../src/main/codegen/data/Parser.tdd | 1 +
.../src/main/codegen/includes/parserImpls.ftl | 21 +--
.../flink/sql/parser/ddl/SqlAlterTableAdd.java | 9 +-
...ark.java => SqlAlterTableDropDistribution.java} | 14 +-
.../flink/sql/parser/ddl/SqlAlterTableModify.java | 9 +-
.../flink/sql/parser/ddl/SqlAlterTableSchema.java | 21 +++
.../flink/sql/parser/ddl/SqlCreateTable.java | 1 +
.../flink/sql/parser/ddl/SqlDistribution.java | 21 ++-
.../flink/sql/parser/FlinkSqlParserImplTest.java | 57 +++++++-
.../operations/ddl/AlterTableChangeOperation.java | 9 ++
.../apache/flink/table/catalog/TableChange.java | 158 +++++++++++++++++++++
.../planner/operations/AlterSchemaConverter.java | 99 +++++++++++--
.../operations/SqlCreateTableConverter.java | 29 +---
.../operations/SqlNodeToOperationConversion.java | 31 ++++
.../planner/utils/OperationConverterUtils.java | 31 ++++
.../operations/SqlDdlToOperationConverterTest.java | 143 +++++++++++++++++--
16 files changed, 578 insertions(+), 76 deletions(-)
copy
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/{SqlAlterTableDropWatermark.java
=> SqlAlterTableDropDistribution.java} (80%)
