Iceberg

在 Flink 控制台元数据管理处支持创建 Iceberg 表，当完成 Iceberg 元数据表创建和配置后，您可以在 SQL 代码中直接进行数据读写，无需额外编写 DDL 语句。

前提条件

您已经完成 Iceberg 元数据表创建和配置。

读数据

元数据表配置完成后，您在 SQL 任务代码编辑区可以直接获取元数据表中的数据，无需额外声明。

INSERT INTO ${other_sink_table}
SELECT ...
FROM iceberg.${DBname}.${Tablename}

• iceberg：Flink 中对表格的命名采用 Catalog.Database.Table 三段式。使用 Iceberg 表时，则需要添加iceberg前缀。
• DBname：数据库名称。
• Tablename：元数据表名称。

写数据

元数据表配置完成后，您在 SQL 任务代码编辑区可以直接往表中写入数据。

INSERT INTO iceberg.${DBname}.${hive_Tablename}
SELECT ... 
FROM ${other_source_table}

• iceberg：Flink 中对表格的命名采用 Catalog.Database.Table 三段式。使用 Iceberg 表时，则需要添加iceberg前缀。
• DBname：数据库名称。
• Tablename：元数据表名称。