04 使用Sqoop将mysql数据导入hbase

    技术2022-07-10  127

    本节演示使用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。

    Processed: 0.009, SQL: 9