Hive示例
更新时间:2025-01-23
前提条件
已完成创建 BMR 集群,并且配置了 Paimon、Hive 组件,详情请参见创建集群。
注意事项
- 由于 Paimon 已经放到 ${HIVE_HOME}/auxlib 目录,所以不需要使用 add jar 就可以直接操作 spark 创建的 paimon 表。
- Hive 不能使用 TEZ 引擎插入数据,并且需要关闭 cbo。参考以下命令:
set hive.execution.engine=mr;
set hive.cbo.enable=false;
操作示例
Hive表
- SSH登录集群,参考SSH连接到集群;
- 执行以下命令查看结果:
drop table if exists hive_paimon;
CREATE TABLE hive_paimon(
id INT COMMENT 'The id field',
name STRING COMMENT 'The name field',
PRIMARY KEY (id) NOT ENFORCED
) CLUSTERED BY (id) INTO 4 BUCKETS
STORED BY 'org.apache.paimon.hive.PaimonStorageHandler';
INSERT INTO hive_paimon VALUES (3, 'hive-Paimon-3');
select * from hive_paimon;
Spark 创建的表
- SSH登录集群,参考SSH连接到集群;
- 执行以下命令查看结果:
show tables;
select * from spark_paimon;
INSERT INTO spark_paimon values (3, 'spark-Paimon-3');
select * from spark_paimon;