小白篇(十一)：sqoop import指令实操

获取原文

 

简短介绍

---

大家好，咳咳~ 这些天感冒了，懈怠了下。现在继续分享下大数据sqoop组件方面的知识。今天主要讲解sqoop import指令，关系型数据导入集群。

 

 

01-关系型导入集群，简单实操

sqoop import指令的作用就是将关系型（RDBMS）数据库中的数据，导入至Hadoop集群的HDFS中。

 

这里以Mysql数据库作为示例。

• 1、先创建mysql测试表

-- 创建表
create table demo.sqoop_test
(
name varchar(10),
address varchar(10)
);
-- 测试数据
insert into demo.sqoop_test(name,address) values
('张三','上海'),
('李四','北京');

测试表和数据截图

 

2、sqoop import将表同步至集群中

执行同步的代码：将sqoop_test同步至hdfs中。

sqoop import --connect 'jdbc:mysql://10.100.157.28:3306/demo?tinyInt1isBit=false'