1）创建表
create 'hive_table','json'
2） 插入了数据如下
hbase(main):012:0> scan 'hive_htable'
ROW                                                          COLUMN+CELL                                                                                                                                                                     

 1                                                           column=json:age, timestamp=1512540521663, value=18                                                                                                                              

 1                                                           column=json:frend, timestamp=1512540630352, value=[{"relationship":1,"phone":"15******7","realName":"addr1"},{"relationship":11,"phone":"13********6","realName":"addr2"}]    
 1                                                           column=json:name, timestamp=1512540375713, value=yinchunguang     
3）创建hive表
create external table  hbase_test (key string ,age string ,name string ,frend string)  STORED BY 'org.apache.hadoop.hive.hbase.HBaseStorageHandler' WITH SERDEPROPERTIES ("hbase.columns.mapping" = ":key,json:age,json:name,json:frend")TBLPROPERTIES ("hbase.table.name"
 = "hive_htable");



4) hive 查询
hive> select * from hbase_test;

OK

1       18      yinchunguang    [{"relationship":1,"phone":"15835809207","realName":"addr1"},{"relationship":11,"phone":"13353588520","realName":"addr2"}]



到此可以进行hive sql on hbase了。
但是presto => hive 不能够从 这个表中查询数据。


重新create table  table_rep as select * from hbase_test
tmp> select json_extract(json_array_get(frend,0), '$.phone') from table_rep;

use cmpay_credit;
-- Create external table for USER in HBase
drop table if exists ex_user;
create external table if not exists ex_user(
rowid                     string,
account_level             string,
name                      string,
boss_brand                string,
credit_level              string,
birthday                  string,
cmpay_id                  string,
fst_consume_day           string,
bind_card_type            string,
score_identity            string,
is_validate               string,
is_black_list             string,
lastest_active_date       string,
score_history_credit      string,
register_date             string,
score_time                string,
user_id                   string,
admiss_date               string,
score_behavior            string,
score_social_cycle        string,
sex                       string,
score_performance         string,
is_real                   string,
mobile_no                 string,
bind_card_amount          string,
cur_year_fst_login_day    string,
score_total               string
) ROW FORMAT SERDE 'org.apache.hadoop.hive.hbase.HBaseSerDe'
stored by 'org.apache.hadoop.hive.hbase.HBaseStorageHandler'
WITH SERDEPROPERTIES(
"hbase.columns.mapping"=":key, cf:account_level, cf:name, cf:boss_brand,
cf:credit_level, cf:birthday, cf:cmpay_id, cf:fst_consume_day,
cf:bind_card_type, cf:score_identity, cf:is_validate, cf:is_black_lisT,
cf:lastest_active_date, cf:score_history_credit, cf:register_date,
cf:score_time, cf:user_id, cf:admiss_date, cf:score_behavior,
cf:score_social_cycle, cf:sex, cf:score_performance, cf:is_real, cf:mobile_no,
cf:bind_card_amount, cf:cur_year_fst_login_day, cf:score_total")
TBLPROPERTIES( "hbase.table.name"="USER");
-- export records of specified fields from ex_user
insert overwrite local directory '/tmp/user_score'
row format delimited fields terminated by ',' select mobile_no, score_behavior,
score_history_credit, score_identity, score_performance, score_social_cycle,
score_total from ex_user;
注意一点
rowid                     string,
对应key

CREATE EXTERNAL TABLE `ood.ods_aim_ki_cords_real_time`(
  `id` bigint, 
  `employeeno` string, 
  `employeename` string, 
  `branchno` string, 
  `postno` string, 
  `teamno` string, 
  `clientid` int, 
  `origin` string, 
  `clientname` string, 
  `contracttype` string, 
  `contractid` int, 
  `status` string, 
  `fillindate` string, 
  `isapprove` boolean, 
  `advice` string, 
  `approveno` string, 
  `approvename` string, 
  `addtime` string, 
  `updatetime` string, 
  `role` string, 
  `branchname` string, 
  `teamname` string)
STORED BY 'org.apache.hadoop.hive.hbase.HBaseStorageHandler'   
WITH SERDEPROPERTIES ("hbase.columns.mapping" =":key,information:EmployeeNo,
information:EmployeeName,
information:BranchNo,
information:PostNo,
information:TeamNo,
information:ClientId,
information:Origin,
information:ClientName,
information:ContractType,
information:ContractId,
information:Status,
information:FillinDate,
information:IsApprove,
information:Advice,
information:ApproveNo,
information:ApproveName,
information:AddTime,
information:UpdateTime,
information:Role,
information:BranchName,
information:TeamName") TBLPROPERTIES("hbase.table.name" = "ai_ki_cords","hbase.mapred.output.outputtable"="ai_ki_cords");

注意：hbase中应当已经存在ai_ki_cords这张表了！

先说下使用场景 ： 

HIve有Orc表 可以增删改 但是每一个事务执行的速度很慢  不适合于高并发的场景。 

我之前mysql同步hadoop  创建了hive事务表  但是效果很差 这里另辟蹊径，将数据存入hbase  很快  建立映射  这样解决了效率问题。

概念 详解： 

HIve有 内部表 和外部表   针对于HBase来说  

外部表 –》HBase已经存在这张表  hive只建立映射   在hive中删除这张表 HBase不收任何影响    在Hive中创建HBase映射的外部表 前提条件 HBase存在这张表 

内部表–》HBase不存在这张表   在HIve中建立HBase映射的内部表 首先HBase不能存在这张表  建立好Hive表会自动在HBase中创建同样结构的表  在Hive中删掉这张表  HBase也会自动删除  

不论内部 外部 disable 表  hive查询会报错



/*##这是创建hive表的基本格式## */
/*这里是外部表     内部表格式不变 去掉external就行*/
create external table student
(id int,
name string,
age int,
sex string,
address string,
math int)

/* #设置hive的存储格式 是hbase##*/

 stored by 'org.apache.hadoop.hive.hbase.HBaseStorageHandler'

 /*这里按照上面hive顺序 与HBase一一对应 :key表示rowKey  info:age代表列族：列*/
 with serdeproperties ("hbase.columns.mapping"="  
 :key,
 info:name,
 info:age,
 info:sex,
 info:address,
 score:math,
 score:english")

/*这里是表的对应关系  对应我  命名空间：表名    当然你可以用默认的命名空间*/
TBLPROPERTIES ("hbase.table.name" = "school:student");