Iceberg

Apache Iceberg 是一个面向海量分析型数据集的开放式表格式。Iceberg 通过高性能的表格式，为 Spark、Trino、PrestoDB、Flink、Hive 和 Impala 等计算引擎添加了表功能，其使用方式与 SQL 表完全一致。

提示

本文假定你已经掌握了 Iceberg 的基础知识与操作。对于本文未涉及的 Iceberg 相关知识，你可以查阅其官方文档。

通过使用 Kyuubi，我们可以对 Iceberg 执行 SQL 查询，这比直接使用 Trino 操作 Iceberg 更加便捷、易于理解且更易扩展。

Iceberg 集成

要通过 Catalog API 启用 Kyuubi Trino SQL 引擎与 Iceberg 的集成，你需要：

• 设置 Trino 扩展与 Catalog 的配置

配置

要启用 Iceberg 的功能，我们可以进行如下配置：

connector.name=iceberg
hive.metastore.uri=thrift://localhost:9083

Iceberg 操作

以 CREATE TABLE 为例，

CREATE TABLE orders (
  orderkey bigint,
  orderstatus varchar,
  totalprice double,
  orderdate date
) WITH (
  format = 'ORC'
);

以 SELECT 为例，

SELECT * FROM new_orders;

以 INSERT 为例，

INSERT INTO cities VALUES (1, 'San Francisco');

以 UPDATE 为例，

UPDATE purchases SET status = 'OVERDUE' WHERE ship_date IS NULL;

以 DELETE FROM 为例，

DELETE FROM lineitem WHERE shipmode = 'AIR';