本节演示使用Sqoop将mysql数据导入hbase。
1、前提约束
- 已安装Sqoop
https://www.jianshu.com/p/c0f8d7ac4ae0 - 已安装mysql并启动
https://www.jianshu.com/p/9a4976b23495 - 已安装hbase
https://www.jianshu.com/p/90d1713d55ce
假设虚拟机所在的Centos服务器ip为192.168.100.141,且已关闭防火墙。
假设sqoop安装目录为 /root/sqoop-1.4.7.bin__hadoop-2.6.0
假设hbase安装目录为 /root/hbase-1.2.6
假设mysql的账号密码为 root/zhangli
2、操作步骤
(1)mysql数据导入hbase
- 在mysql中初始化数据,执行以下命令:
mysql -uroot -pzhangli
create database test;
use test;
create table t_info(id int,name varchar(20),age int);
insert into t_info(id,name,age) values(1,'ali',20);
insert into t_info(id,name,age) values(2,'xiaoli',3);
exit;
- 在hbase中初始化表,执行以下命令:
cd /root/hbase-1.2.6/bin
./hbase
create 't1','f1'
exit
- 把mysql数据导入hbase
cd /root/hbase-1.2.6
./sqoop import --connect jdbc:mysql://localhost:3306/test --username root --password zhangli --table t_user --hbase-table t1 --column-family f1 --hbase-create-table --hbase-row-key id
如此,就完成了把mysql导入了hbase。
网友评论