向user表中插入一些数据:
put 'user1','1','info:name','zhangsan'
put 'user1','1','info:age','25'
put 'user1','2','info:name','lisi'
put 'user1','2','info:age','22'
put 'user1','3','info:name','wangswu'
put 'user1','3','info:age','21'
SET hbase.zookeeper.quorum=slave1(主机名);
SET zookeeper.znode.parent=/hbase;
ADD jar/usr/tools/hive-1.2.1-bin/lib/hive-hbase-handler-1.2.1.jar;
// user1表:
CREATE EXTERNAL TABLE user1 (
rowkey string,
info map<STRING,STRING>
) STORED BY 'org.apache.hadoop.hive.hbase.HBaseStorageHandler'
WITH SERDEPROPERTIES ("hbase.columns.mapping" = ":key,info:")
TBLPROPERTIES ("hbase.table.name" = "user1"); // user2表:
CREATE EXTERNAL TABLE user2 (
rowkey string,
name string,
age int
) STORED BY 'org.apache.hadoop.hive.hbase.HBaseStorageHandler'
WITH SERDEPROPERTIES ("hbase.columns.mapping" = ":key,info:name,info:age")
TBLPROPERTIES ("hbase.table.name" = "user2");
查询user1,user2表数据
查询user1表数据
select * from user1;
结果如下
OK
1 {"age":"25","name":"zhangsan"}
2 {"age":"22","name":"lisi"}
3 {"age":"21","name":"wangswu"}
Time taken: 0.467 seconds, Fetched: 3 row(s)
查询user2表数据
select * from user2;
结果如下:
OK
1 zhangsan 25
2 lisi 22
3 wangswu 21
Time taken: 0.087 seconds, Fetched: 3 row(s) hive插入数据到hbase:
INSERT INTO TABLE user1
SELECT '4' AS rowkey,
map('name','lijin','age','22') AS info
from dual limit 1;