sqoop将数据从MySQL导入_使用sqoop将数据从mysql导入到hive

参考文档&＃xff1a;https://segmentfault.com/a/1190000002532293

测试环境&＃xff1a;

完全分布式安装Hadoop

Hive安装(使用默认的derby存储元数据)

sqoop的安装

当然还是mysql已安装(使用iso文件建立本地仓库)

测试数据

MariaDB [(none)]> use testdb;

Reading table information for completion of table and column names

You can turn off this feature to get a quicker startup with -A

Database changed

MariaDB [testdb]> select * from emp;

&＃43;------&＃43;---------&＃43;--------------&＃43;--------&＃43;------&＃43;

| id | name | deg | salary | dept |

&＃43;------&＃43;---------&＃43;--------------&＃43;--------&＃43;------&＃43;

| 1201 | gopal | manmager | 50000 | TP |

| 1202 | manisha | Proof reader | 50000 | TP |

| 1203 | kalil | php dev | 50000 | TP |

&＃43;------&＃43;---------&＃43;--------------&＃43;--------&＃43;------&＃43;

3 rows in set (0.00 sec)

MariaDB [testdb]>

导入数据

[root&＃64;master conf]# sqoop import --connect jdbc:mysql://localhost:3306/testdb --username root --password 000000 --table emp --fields-terminated-by &＃39;\t&＃39; --lines-terminated-by "\n" --hive-import --hive-overwrite --create-hive-table --hive-table emp --delete-target-dir