hbase中表关联到hive然后使用sql查询

本文主要是介绍hbase中表关联到hive然后使用sql查询，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

hbase中的'user_position_table'表实时关联到hive

hive

创建表

 create external table hive_user_position_table
(
  id   string,
  lacCell string,
  lacCoordinate string,
  msisdn string,
  timestamp string
)
STORED BY 'org.apache.hadoop.hive.hbase.HBaseStorageHandler' 
WITH SERDEPROPERTIES("hbase.columns.mapping" = ":key,position:lacCell,position:lacCoordinate,position:msisdn,position:timestamp")
TBLPROPERTIES("hbase.table.name" = "user_position_table");

在hive中查看数据

select * from user_position_table_tmp where msisdn=13641999428; 

hive> create external table hive_user_position_table
    > (
    >   id   string,
    >   lacCell string,
    >   lacCoordinate string,
    >   msisdn string,
    >   timestamp string
    > )
    > STORED BY 'org.apache.hadoop.hive.hbase.HBaseStorageHandler' 
    > WITH SERDEPROPERTIES("hbase.columns.mapping" = ":key,position:lacCell,position:lacCoordinate,position:msisdn,position:timestamp")
    > TBLPROPERTIES("hbase.table.name" = "user_position_table");
OK
Time taken: 3.344 seconds
hive>  select * from user_position_table_tmp where msisdn=13641999428; 
WARNING: Comparing a bigint and a string may result in a loss of precision.
Total jobs = 1
Launching Job 1 out of 1
Number of reduce tasks is set to 0 since there's no reduce operator
Starting Job = job_1466479961681_0610, Tracking URL = http://vhost79.test.quality:8088/proxy/application_1466479961681_0610/

这篇关于hbase中表关联到hive然后使用sql查询的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---