Skip to content

Commit 756937e

Browse files
committed
[doc]Adjust ddl.md document structure
1 parent bc49735 commit 756937e

File tree

1 file changed

+19
-18
lines changed

1 file changed

+19
-18
lines changed

website/docs/engine-flink/ddl.md

Lines changed: 19 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ USE CATALOG fluss_catalog;
3939

4040
The following properties can be set if using the Fluss catalog:
4141

42-
| Option | Required | Default | Description |
42+
| Option | Required | Default | Description |
4343
|--------------------------------|----------|-----------|--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
4444
| type | required | (none) | Catalog type, must to be 'fluss' here. |
4545
| bootstrap.servers | required | (none) | Comma separated list of Fluss servers. |
@@ -238,6 +238,24 @@ DROP TABLE my_table;
238238

239239
This will entirely remove all the data of the table in the Fluss cluster.
240240

241+
## Add Partition
242+
243+
Fluss support manually add partitions to an exists partitioned table by Fluss Catalog. If the specified partition
244+
not exists, Fluss will create the partition. If the specified partition already exists, Fluss will ignore the request
245+
or throw an exception.
246+
247+
To add partitions, run:
248+
249+
```sql title="Flink SQL"
250+
-- Add a partition to a single field partitioned table
251+
ALTER TABLE my_part_pk_table ADD PARTITION (dt = '2025-03-05');
252+
253+
-- Add a partition to a multi-field partitioned table
254+
ALTER TABLE my_multi_fields_part_log_table ADD PARTITION (dt = '2025-03-05', nation = 'US');
255+
```
256+
257+
For more details, refer to the [Flink ALTER TABLE(ADD)](https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/dev/table/sql/alter/#add) documentation.
258+
241259
## Show Partitions
242260

243261
To show all the partitions of a partitioned table, run:
@@ -257,23 +275,6 @@ SHOW PARTITIONS my_multi_fields_part_log_table PARTITION (dt = '2025-03-05', nat
257275

258276
For more details, refer to the [Flink SHOW PARTITIONS](https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/dev/table/sql/show/#show-partitions) documentation.
259277

260-
## Add Partition
261-
262-
Fluss support manually add partitions to an exists partitioned table by Fluss Catalog. If the specified partition
263-
not exists, Fluss will create the partition. If the specified partition already exists, Fluss will ignore the request
264-
or throw an exception.
265-
266-
To add partitions, run:
267-
```sql title="Flink SQL"
268-
-- Add a partition to a single field partitioned table
269-
ALTER TABLE my_part_pk_table ADD PARTITION (dt = '2025-03-05');
270-
271-
-- Add a partition to a multi-field partitioned table
272-
ALTER TABLE my_multi_fields_part_log_table ADD PARTITION (dt = '2025-03-05', nation = 'US');
273-
```
274-
275-
For more details, refer to the [Flink ALTER TABLE(ADD)](https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/dev/table/sql/alter/#add) documentation.
276-
277278
## Drop Partition
278279

279280
Fluss also support manually drop partitions from an exists partitioned table by Fluss Catalog. If the specified partition

0 commit comments

Comments
 (0)