You need to enable JavaScript to run this app.
导航
Iceberg
最近更新时间:2023.11.08 15:34:44首次发布时间:2023.09.12 16:22:50

在 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:元数据表名称。