一、概述

Iceberg 的架构和实现并未绑定于某一特定引擎,它实现了通用的数据组织格式,利用此格式可以方便地与不同引擎(如Flink、Hive、Spark)对接。Flink 和 Iceberg 的集成可以提供更好的数据管理和分析功能,可以更好地管理和分析大型数据集。

  1. https://mp.weixin.qq.com/s/jIcQbpj1OtQ71m6YFCItng
  2. https://blog.csdn.net/yiweiyi329/article/details/121842572
  3. https://juejin.cn/post/6961912479215517703

二、读数据

三、写数据

IcebergTableSink 可以将数据写入 Iceberg 表中,使用 IcebergTableSink, 可以轻松地将数据湖中的数据进行写入和管理。

四、删除数据

五、修改数据