Hive 支持通过内表或外表的方式访问 Iceberg 数据,接下来为您介绍如何使用 LAS 上的 Hive 访问 Iceberg 数据。
hive
也可以采用beeline命令,举例:
beeline -u jdbc:hive2://master-1-1:10000/default -n hive -p <hive用户的密码>
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;
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');
-- 更改Hive的执行引擎为mrSET hive.execution.engine = mr; INSERT INTO iceberg_db.table_a1 VALUES(0, 'a'); sql
说明
对于 INSERT 操作,只支持 mr 引擎 。
SELECT * FROM iceberg_db.table_a1; sql
DROP TABLE IF EXISTS iceberg_db.table_a1;
说明
删除表,也会将表的数据进行删除,但在HDFS上会留存表名的相关空目录。