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