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 94c65494b20 [FLINK-38441][runtime] Fix
ExecutionGraphCoLocationRestartTest failures (#27060)
add e93fd02a31d [hotfix] Move `MergeTableAsUtil` and `SchemaBuilderUtil`
to `converters` package
add 3173d08e45d [FLINK-38856][table] Generalize ALTER TABLE ... DROP
converters and sql objects
add 9215bcd8c60 [FLINK-38856][table] Add support for ALTER MATERIALIZED
TABLE DROP schema component
add ee484f61e9d [FLINK-38856][table] Move materialized table converters to
`materializedtable` package
add 76337add10b [FLINK-38856][table] Move `AnalyzeTable`,
`CreateFunction`, `AlterFunction`, `DropFunction` to dedicated converters
No new revisions were added by this update.
Summary of changes:
.../src/main/codegen/data/Parser.tdd | 14 +-
.../src/main/codegen/includes/parserImpls.ftl | 49 ++-
.../SqlAlterMaterializedTableDropDistribution.java | 3 +-
.../SqlAlterMaterializedTableSchema.java | 128 ++++++-
.../SqlDropMaterializedTable.java | 8 +
.../sql/parser/ddl/table/SqlAlterTableDrop.java | 187 +++++++++++
.../parser/ddl/table/SqlAlterTableDropColumn.java | 76 -----
.../ddl/table/SqlAlterTableDropConstraint.java | 66 ----
.../ddl/table/SqlAlterTableDropPrimaryKey.java | 47 ---
.../ddl/table/SqlAlterTableDropWatermark.java | 56 ----
.../MaterializedTableStatementParserTest.java | 21 ++
.../operations/SqlNodeToOperationConversion.java | 369 ---------------------
.../converters/{table => }/MergeTableAsUtil.java | 2 +-
.../converters/{table => }/MergeTableLikeUtil.java | 11 +-
.../converters/{table => }/SchemaBuilderUtil.java | 2 +-
.../operations/converters/SchemaConverter.java | 20 +-
.../converters/SchemaReferencesManager.java | 76 ++++-
.../converters/SqlAlterFunctionConverter.java | 56 ++++
.../converters/SqlCreateFunctionConverter.java | 72 ++++
.../converters/SqlCreateModelConverter.java | 1 -
...onverter.java => SqlDropFunctionConverter.java} | 28 +-
.../operations/converters/SqlNodeConverters.java | 48 ++-
.../AbstractAlterMaterializedTableConverter.java | 3 +-
.../AbstractCreateMaterializedTableConverter.java | 3 +-
...rMaterializedTableAddDistributionConverter.java | 2 +-
.../SqlAlterMaterializedTableAsQueryConverter.java | 2 +-
...MaterializedTableDropDistributionConverter.java | 2 +-
...lAlterMaterializedTableDropSchemaConverter.java | 216 ++++++++++++
...terializedTableModifyDistributionConverter.java | 2 +-
.../SqlAlterMaterializedTableRefreshConverter.java | 3 +-
.../SqlAlterMaterializedTableResumeConverter.java | 3 +-
.../SqlAlterMaterializedTableSchemaConverter.java | 7 +-
.../SqlAlterMaterializedTableSuspendConverter.java | 3 +-
...SqlCreateOrAlterMaterializedTableConverter.java | 4 +-
.../SqlDropMaterializedTableConverter.java | 3 +-
.../table/AbstractAlterTableConverter.java | 18 +-
.../table/SqlAlterTableDropColumnConverter.java | 102 ------
.../SqlAlterTableDropConstraintConverter.java | 72 ----
.../SqlAlterTableDropPrimaryKeyConverter.java | 61 ----
.../table/SqlAlterTableDropWatermarkConverter.java | 60 ----
.../table/SqlAlterTableRenameColumnConverter.java | 9 +-
.../table/SqlAlterTableSchemaAddConverter.java | 37 ---
.../table/SqlAlterTableSchemaConverter.java | 151 ++++++++-
.../table/SqlAlterTableSchemaModifyConverter.java | 36 --
.../converters/table/SqlAnalyzeTableConverter.java | 260 +++++++++++++++
.../table/SqlCreateTableAsConverter.java | 1 +
.../converters/table/SqlCreateTableConverter.java | 1 +
.../table/SqlCreateTableLikeConverter.java | 1 +
.../table/SqlReplaceTableAsConverter.java | 1 +
.../planner/utils/MaterializedTableUtils.java | 23 +-
.../planner/utils/OperationConverterUtils.java | 166 +++++++++
.../operations/SqlDdlToOperationConverterTest.java | 82 +++--
...erializedTableNodeToOperationConverterTest.java | 114 ++++++-
.../{table => }/MergeTableLikeUtilTest.java | 173 ++++------
54 files changed, 1721 insertions(+), 1240 deletions(-)
create mode 100644
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/table/SqlAlterTableDrop.java
delete mode 100644
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/table/SqlAlterTableDropColumn.java
delete mode 100644
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/table/SqlAlterTableDropConstraint.java
delete mode 100644
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/table/SqlAlterTableDropPrimaryKey.java
delete mode 100644
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/table/SqlAlterTableDropWatermark.java
rename
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/{table
=> }/MergeTableAsUtil.java (99%)
rename
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/{table
=> }/MergeTableLikeUtil.java (98%)
rename
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/{table
=> }/SchemaBuilderUtil.java (99%)
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/SqlAlterFunctionConverter.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/SqlCreateFunctionConverter.java
copy
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/{SqlDescribeModelConverter.java
=> SqlDropFunctionConverter.java} (52%)
rename
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/{
=> materializedtable}/AbstractAlterMaterializedTableConverter.java (96%)
rename
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/{
=> materializedtable}/AbstractCreateMaterializedTableConverter.java (98%)
rename
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/{
=> materializedtable}/SqlAlterMaterializedTableAddDistributionConverter.java
(97%)
rename
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/{
=> materializedtable}/SqlAlterMaterializedTableAsQueryConverter.java (98%)
rename
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/{
=> materializedtable}/SqlAlterMaterializedTableDropDistributionConverter.java
(96%)
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/materializedtable/SqlAlterMaterializedTableDropSchemaConverter.java
rename
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/{
=>
materializedtable}/SqlAlterMaterializedTableModifyDistributionConverter.java
(97%)
rename
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/{
=> materializedtable}/SqlAlterMaterializedTableRefreshConverter.java (92%)
rename
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/{
=> materializedtable}/SqlAlterMaterializedTableResumeConverter.java (92%)
rename
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/{
=> materializedtable}/SqlAlterMaterializedTableSchemaConverter.java (96%)
rename
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/{
=> materializedtable}/SqlAlterMaterializedTableSuspendConverter.java (91%)
rename
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/{
=> materializedtable}/SqlCreateOrAlterMaterializedTableConverter.java (98%)
rename
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/{
=> materializedtable}/SqlDropMaterializedTableConverter.java (92%)
delete mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/table/SqlAlterTableDropColumnConverter.java
delete mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/table/SqlAlterTableDropConstraintConverter.java
delete mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/table/SqlAlterTableDropPrimaryKeyConverter.java
delete mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/table/SqlAlterTableDropWatermarkConverter.java
delete mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/table/SqlAlterTableSchemaAddConverter.java
delete mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/table/SqlAlterTableSchemaModifyConverter.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/table/SqlAnalyzeTableConverter.java
rename
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/converters/{table
=> }/MergeTableLikeUtilTest.java (87%)
