Skip to content

Commit 6bb02da

Browse files
ClaireLyttClaireLytt
authored
[Improve][Connector-V2][Iceberg] Align OptionRule with docs and strengthen factory test (#11675)
1 parent 65e32aa commit 6bb02da

7 files changed

Lines changed: 196 additions & 19 deletions

File tree

‎docs/en/connectors/sink/Iceberg.md‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -64,9 +64,9 @@ libfb303-xxx.jar
6464

6565
| Name | Type | Required | Default | Description |
6666
|----------------------------------------|---------|----------|------------------------------|---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
67-
| catalog_name | string | yes | default | User-specified catalog name. default is `default` |
68-
| namespace | string | yes | default | The iceberg database name in the backend catalog. default is `default` |
69-
| table | string | yes | - | The iceberg table name in the backend catalog. |
67+
| catalog_name | string | no | default | User-specified catalog name. default is `default` |
68+
| namespace | string | no | default | The iceberg database name in the backend catalog. default is `default` |
69+
| table | string | no | - | The iceberg table name in the backend catalog. If not set, the table name of the upstream table is used. |
7070
| iceberg.catalog.config | map | yes | - | Specify the properties for initializing the Iceberg catalog, which can be referenced in this file: [CatalogProperties.java](https://github.com/apache/iceberg/blob/main/core/src/main/java/org/apache/iceberg/CatalogProperties.java) |
7171
| hadoop.config | map | no | - | Properties passed through to the Hadoop configuration |
7272
| iceberg.hadoop-conf-path | string | no | - | The specified loading paths for the 'core-site.xml', 'hdfs-site.xml', 'hive-site.xml' files. |

‎docs/en/connectors/source/Iceberg.md‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -75,8 +75,8 @@ libfb303-xxx.jar
7575

7676
| Name | Type | Required | Default | Description |
7777
|--------------------------|---------|----------|----------------------|------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
78-
| catalog_name | string | yes | - | User-specified catalog name. |
79-
| namespace | string | yes | - | The iceberg database name in the backend catalog. |
78+
| catalog_name | string | no | default | User-specified catalog name. |
79+
| namespace | string | no | default | The iceberg database name in the backend catalog. |
8080
| table | string | no | - | The Iceberg table name in the backend catalog. Configure exactly one of `table` and `table_list`. |
8181
| table_list | list | no | - | The Iceberg table list in the backend catalog. Configure exactly one of `table` and `table_list`. Each item can set `table`, `query`, and snapshot/stream scan options for that table. |
8282
| iceberg.catalog.config | map | yes | - | Specify the properties for initializing the Iceberg catalog, which can be referenced in this file: [CatalogProperties.java](https://github.com/apache/iceberg/blob/main/core/src/main/java/org/apache/iceberg/CatalogProperties.java) |

‎docs/zh/connectors/sink/Iceberg.md‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -64,9 +64,9 @@ libfb303-xxx.jar
6464

6565
| 名称 | 类型 | 是否必须 | 默认 | 描述 |
6666
|----------------------------------------|---------|------|------------------------------|-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
67-
| catalog_name | string | yes | default | 用户指定的目录名称，默认为`default` |
68-
| namespace | string | yes | default | backend catalog（元数据存储的后端目录）中 Iceberg 数据库的名称，默认为 `default` |
69-
| table | string | yes | - | backend catalog（元数据存储的后端目录）中 Iceberg 表的名称 |
67+
| catalog_name | string | no | default | 用户指定的目录名称，默认为`default` |
68+
| namespace | string | no | default | backend catalog（元数据存储的后端目录）中 Iceberg 数据库的名称，默认为 `default` |
69+
| table | string | no | - | backend catalog（元数据存储的后端目录）中 Iceberg 表的名称。不配置时使用上游表的表名 |
7070
| iceberg.catalog.config | map | yes | - | 用于指定初始化 Iceberg Catalog 的属性，这些属性可以参考此文件：[CatalogProperties.java](https://github.com/apache/iceberg/blob/main/core/src/main/java/org/apache/iceberg/CatalogProperties.java) |
7171
| hadoop.config | map | no | - | 传递给 Hadoop 配置的属性 |
7272
| iceberg.hadoop-conf-path | string | no | - | 指定`core-site.xml`、`hdfs-site.xml`、`hive-site.xml` 文件的加载路径 |

0 commit comments

Comments
 (0)