Hive 支持通过内表或外表的方式访问 Iceberg 数据，接下来为您介绍如何使用 LAS 上的 Hive 访问 Iceberg 数据。

操作步骤 #

1. 使用 SSH 方式登录到集群节点。
2. 在集群主机 Linux Bash 中执行如下进入Hive命令行。

hive

也可以采用beeline命令，举例：

beeline -u jdbc:hive2://master-1-1:10000/default -n hive -p <hive用户的密码>

3. 配置 Iceberg 的 Catalog信息。

Hive 中支持 Iceberg 的 Catalog type 有 Hive、Hadoop，也可以为空。 type 不同，配置项也不同。可参考上文参数配置章节。下面以 Hive 类型为例，创建 Catalog 名称为 Iceberg：

SET iceberg.catalog.iceberg.type=hive;
SET iceberg.catalog.iceberg.uri=thrift://master-1-1:9083;
SET iceberg.catalog.iceberg.clients=10;

4. 创建表。

CREATE DATABASE IF NOT EXISTS iceberg_db;

CREATE EXTERNAL TABLE iceberg_db.table_a1(i INT, s STRING)
STORED BY 'org.apache.iceberg.mr.hive.HiveIcebergStorageHandler'
TBLPROPERTIES ('iceberg.catalog'='iceberg');

5. 插入数据。

-- 更改Hive的执行引擎为mrSET hive.execution.engine = mr;
INSERT INTO iceberg_db.table_a1 VALUES(0, 'a');
sql

6. 查询表。

SELECT * FROM iceberg_db.table_a1;
sql

7. 删除表。

DROP TABLE IF EXISTS iceberg_db.table_a1;