raminqaf commented on code in PR #27846:
URL: https://github.com/apache/flink/pull/27846#discussion_r3009539980
##########
docs/content.zh/docs/sql/materialized-table/statements.md:
##########
@@ -383,15 +391,123 @@ CREATE OR ALTER MATERIALIZED TABLE my_materialized_table
# ALTER MATERIALIZED TABLE
-```
+```text
ALTER MATERIALIZED TABLE [catalog_name.][db_name.]table_name
- SUSPEND | RESUME [WITH (key1=val1, key2=val2, ...)] |
- REFRESH [PARTITION partition_spec] |
- AS <select_statement>
+ ADD { <schema_component> | (<schema_component> [, ...]) | <distribution> }
+ | MODIFY { <schema_component> | (<schema_component> [, ...]) |
<distribution> }
+ | DROP {column_name | (column_name, column_name, ....) | PRIMARY KEY |
CONSTRAINT constraint_name | WATERMARK | DISTRIBUTION }
Review Comment:
```suggestion
| DROP {column_name | (column_name, column_name, ...) | PRIMARY KEY |
CONSTRAINT constraint_name | WATERMARK | DISTRIBUTION }
```
##########
docs/content.zh/docs/sql/materialized-table/statements.md:
##########
@@ -383,15 +391,123 @@ CREATE OR ALTER MATERIALIZED TABLE my_materialized_table
# ALTER MATERIALIZED TABLE
-```
+```text
ALTER MATERIALIZED TABLE [catalog_name.][db_name.]table_name
- SUSPEND | RESUME [WITH (key1=val1, key2=val2, ...)] |
- REFRESH [PARTITION partition_spec] |
- AS <select_statement>
+ ADD { <schema_component> | (<schema_component> [, ...]) | <distribution> }
+ | MODIFY { <schema_component> | (<schema_component> [, ...]) |
<distribution> }
+ | DROP {column_name | (column_name, column_name, ....) | PRIMARY KEY |
CONSTRAINT constraint_name | WATERMARK | DISTRIBUTION }
+ | SUSPEND | RESUME [WITH (key1=val1, key2=val2, ...)] |
Review Comment:
```suggestion
| SUSPEND | RESUME [WITH (key1=val1, key2=val2, ...)]
```
##########
docs/content.zh/docs/sql/materialized-table/statements.md:
##########
@@ -383,15 +391,123 @@ CREATE OR ALTER MATERIALIZED TABLE my_materialized_table
# ALTER MATERIALIZED TABLE
-```
+```text
ALTER MATERIALIZED TABLE [catalog_name.][db_name.]table_name
- SUSPEND | RESUME [WITH (key1=val1, key2=val2, ...)] |
- REFRESH [PARTITION partition_spec] |
- AS <select_statement>
+ ADD { <schema_component> | (<schema_component> [, ...]) | <distribution> }
+ | MODIFY { <schema_component> | (<schema_component> [, ...]) |
<distribution> }
+ | DROP {column_name | (column_name, column_name, ....) | PRIMARY KEY |
CONSTRAINT constraint_name | WATERMARK | DISTRIBUTION }
+ | SUSPEND | RESUME [WITH (key1=val1, key2=val2, ...)] |
+ | REFRESH [PARTITION partition_spec] |
+ | AS <select_statement>
+<schema_component>:
+ { <column_component> | <constraint_component> | <watermark_component> }
+
+<column_component>:
+ column_name <column_definition> [FIRST | AFTER column_name]
+
+<constraint_component>:
+ [CONSTRAINT constraint_name] PRIMARY KEY (column_name, ...) NOT ENFORCED
+
+<watermark_component>:
+ WATERMARK FOR rowtime_column_name AS watermark_strategy_expression
+
+<column_definition>:
+ { <physical_column_definition> | <metadata_column_definition> |
<computed_column_definition> } [COMMENT column_comment]
+
+<physical_column_definition>:
+ column_type
+
+<metadata_column_definition>:
+ column_type METADATA [ FROM metadata_key ] [ VIRTUAL ]
+
+<computed_column_definition>:
+ AS computed_column_expression
+
+<distribution>:
+{
+ DISTRIBUTION BY [ { HASH | RANGE } ] (bucket_column_name1,
bucket_column_name2, ...) ] [INTO n BUCKETS]
+ | DISTRIBUTION INTO n BUCKETS
Review Comment:
```suggestion
DISTRIBUTION BY [ { HASH | RANGE } ] (bucket_column_name1,
bucket_column_name2, ...) [INTO n BUCKETS]
| DISTRIBUTION INTO n BUCKETS
```
##########
docs/content.zh/docs/sql/materialized-table/statements.md:
##########
@@ -383,15 +391,123 @@ CREATE OR ALTER MATERIALIZED TABLE my_materialized_table
# ALTER MATERIALIZED TABLE
-```
+```text
ALTER MATERIALIZED TABLE [catalog_name.][db_name.]table_name
- SUSPEND | RESUME [WITH (key1=val1, key2=val2, ...)] |
- REFRESH [PARTITION partition_spec] |
- AS <select_statement>
+ ADD { <schema_component> | (<schema_component> [, ...]) | <distribution> }
+ | MODIFY { <schema_component> | (<schema_component> [, ...]) |
<distribution> }
+ | DROP {column_name | (column_name, column_name, ....) | PRIMARY KEY |
CONSTRAINT constraint_name | WATERMARK | DISTRIBUTION }
+ | SUSPEND | RESUME [WITH (key1=val1, key2=val2, ...)] |
+ | REFRESH [PARTITION partition_spec] |
+ | AS <select_statement>
+<schema_component>:
+ { <column_component> | <constraint_component> | <watermark_component> }
+
+<column_component>:
+ column_name <column_definition> [FIRST | AFTER column_name]
+
+<constraint_component>:
+ [CONSTRAINT constraint_name] PRIMARY KEY (column_name, ...) NOT ENFORCED
+
+<watermark_component>:
+ WATERMARK FOR rowtime_column_name AS watermark_strategy_expression
+
+<column_definition>:
+ { <physical_column_definition> | <metadata_column_definition> |
<computed_column_definition> } [COMMENT column_comment]
+
+<physical_column_definition>:
+ column_type
+
+<metadata_column_definition>:
+ column_type METADATA [ FROM metadata_key ] [ VIRTUAL ]
+
+<computed_column_definition>:
+ AS computed_column_expression
+
+<distribution>:
+{
+ DISTRIBUTION BY [ { HASH | RANGE } ] (bucket_column_name1,
bucket_column_name2, ...) ] [INTO n BUCKETS]
+ | DISTRIBUTION INTO n BUCKETS
+}
```
`ALTER MATERIALIZED TABLE`
用于管理物化表。用户可以使用此命令暂停和恢复物化表的刷新管道，并手动触发数据刷新，以及修改物化表的查询定义。
+## ADD
+Use `ADD` clause to add [columns]({{< ref "docs/sql/reference/ddl/create"
>}}#columns) (only non persisted like computed and metadata virtual),
[constraints]({{< ref "docs/sql/reference/ddl/create" >}}#primary-key), a
[watermark]({{< ref "docs/sql/reference/ddl/create" >}}#watermark), and a
[distribution]({{< ref "docs/sql/reference/ddl/create" >}}#distributed) to an
existing materialized table.
+
+To add a column at the specified position, use `FIRST` or `AFTER col_name`. By
default, the column is appended at last.
+
+The following examples illustrate the usage of the `ADD` statements.
+
+```sql
+-- add a new column
+ALTER MATERIALIZED TABLE MyMateralizedTable ADD category_id STRING METADATA
VIRTUAL;
Review Comment:
Here and everywhere else too:
```suggestion
ALTER MATERIALIZED TABLE MyMaterializedTable ADD category_id STRING METADATA
VIRTUAL;
```
##########
docs/content/docs/sql/materialized-table/statements.md:
##########
@@ -382,15 +390,125 @@ CREATE OR ALTER MATERIALIZED TABLE my_materialized_table
# ALTER MATERIALIZED TABLE
-```
+```text
ALTER MATERIALIZED TABLE [catalog_name.][db_name.]table_name
- SUSPEND | RESUME [WITH (key1=val1, key2=val2, ...)] |
- REFRESH [PARTITION partition_spec] |
- AS <select_statement>
+ ADD { <schema_component> | (<schema_component> [, ...]) | <distribution> }
+ | MODIFY { <schema_component> | (<schema_component> [, ...]) |
<distribution> }
+ | DROP {column_name | (column_name, column_name, ....) | PRIMARY KEY |
CONSTRAINT constraint_name | WATERMARK | DISTRIBUTION }
+ | SUSPEND | RESUME [WITH (key1=val1, key2=val2, ...)] |
+ | REFRESH [PARTITION partition_spec] |
+ | AS <select_statement>
+<schema_component>:
+ { <column_component> | <constraint_component> | <watermark_component> }
+
+<column_component>:
+ column_name <column_definition> [FIRST | AFTER column_name]
+
+<constraint_component>:
+ [CONSTRAINT constraint_name] PRIMARY KEY (column_name, ...) NOT ENFORCED
+
+<watermark_component>:
+ WATERMARK FOR rowtime_column_name AS watermark_strategy_expression
+
+<column_definition>:
+ { <physical_column_definition> | <metadata_column_definition> |
<computed_column_definition> } [COMMENT column_comment]
+
+<physical_column_definition>:
+ column_type
+
+<metadata_column_definition>:
+ column_type METADATA [ FROM metadata_key ] [ VIRTUAL ]
+
+<computed_column_definition>:
+ AS computed_column_expression
+
+<distribution>:
+{
+ DISTRIBUTION BY [ { HASH | RANGE } ] (bucket_column_name1,
bucket_column_name2, ...) ] [INTO n BUCKETS]
Review Comment:
```suggestion
DISTRIBUTION BY [ { HASH | RANGE } ] (bucket_column_name1,
bucket_column_name2, ...) [INTO n BUCKETS]
```
--
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]
