本文共 1899 字,大约阅读时间需要 6 分钟。
一.使用hive获取,HBASE中数据1.create 'hadoop:hbase_hive_human','info'2.造数put 'hadoop:hbase_hive_human','1','info:id','1'put 'hadoop:hbase_hive_human','1','info:name','wang'put 'hadoop:hbase_hive_human','1','info:age',18 put 'hadoop:hbase_hive_human','2','info:id','2'put 'hadoop:hbase_hive_human','2','info:name','wang'put 'hadoop:hbase_hive_human','2','info:age',18 put 'hadoop:hbase_hive_human','3','info:id','3'put 'hadoop:hbase_hive_human','3','info:name','wang'put 'hadoop:hbase_hive_human','3','info:age',18 put 'hadoop:hbase_hive_human','4','info:id','4'put 'hadoop:hbase_hive_human','4','info:name','wang'put 'hadoop:hbase_hive_human','4','info:age',18put 'hadoop:hbase_hive_human','5','info:id','5'put 'hadoop:hbase_hive_human','5','info:name','wang'put 'hadoop:hbase_hive_human','5','info:age',18 3.创建一个create external table hive.hbase_hive_human(rowkey string,id int,name string ) stored by 'org.apache.hadoop.hive.hbase.HBaseStorageHandler' with serdeproperties ("hbase.columns.mapping" = ":key,info:id,info:name" ,"hbase.table.name" = "hadoop:hbase_hive_human");或create external table hive.hbase_hive_human(rowkey string,id int,name string ) stored by 'org.apache.hadoop.hive.hbase.HBaseStorageHandler' with serdeproperties ("hbase.columns.mapping" = ":key,info:id,info:name") tblproperties ("hbase.table.name" = "hadoop:hbase_hive_human");
二.利用hive把hdfs中数据导入hbasesqoop只能把数据导入到hdfs中,所有可以利用hive 再把hdfs中数据导入hbase中1.创建一个hive表create table hive.hivetohbase(id int,name string,age int ) stored by 'org.apache.hadoop.hive.hbase.HBaseStorageHandler' with serdeproperties ("hbase.columns.mapping" = ":key,info:name,info:age","hbase.table.name" = "hadoop:hivetohbase");不能直接从本地导入到该表(报错)load data local inpath '/home/wang/a/1.txt' INTO TABLE hive.hivetohbase;可以使用以下方式插入数据:insert into table hive.hivetohbase select id,name,age from st;insert OVERWRITE table hive.hivetohbase select id,name,age from st;
转载地址:http://orjxi.baihongyu.com/