Kudu简单使用

Posted 2022-01-19 光于前裕于后

环境版本：CDH 6.3.2 | Impala 3.2.0 | Hive 2.1.1 | Hue 4.2.0 | kudu 1.10.0

# 创建kudu表，需指定主键、分区
CREATE TABLE kudu_table
(
  id BIGINT,
  name STRING,
  PRIMARY KEY(id)
)
PARTITION BY HASH PARTITIONS 16
STORED AS KUDU;

# 创建impala外部表映射kudu表
CREATE EXTERNAL TABLE test.mapping_table
STORED AS KUDU
TBLPROPERTIES (
  'kudu.table_name' = 'test.kudu_table'
);

# 查
SELECT * FROM kudu_table;

# 删表
DROP table kudu_table;

# 增
INSERT INTO kudu_table VALUES (99, "sarah");
INSERT INTO kudu_table VALUES (0, "tom");
INSERT INTO kudu_table VALUES (1, "john");

# 有则更新，没有新增
UPSERT INTO kudu_table VALUES (88, "guo");
UPSERT INTO kudu_table VALUES (99, "guo");

# 改
UPDATE kudu_table SET name="bob" where id = 99;

# 删，支持条件删除
DELETE FROM kudu_table WHERE id > 88;

INVALIDATE METADATA;

需要注意的是，创建的kudu表和impala外部表映射kudu表都无法使用hive查询，hive也无法创建。默认不支持，不知道是否可配。
此外，建kudu表需至少有三个tablet。

官方文档：https://kudu.apache.org/docs/kudu_impala_integration.html