hadoop—使用sqoop将rdbms中的列子集导入配置单元表

h5qlskok  于 2021-06-01  发布在  Hadoop
关注(0)|答案(1)|浏览(396)

假设我们有一个名为 lastdb 带table person . 此表包含4列,称为: id , firstname , lastname , age .
行内 person 表格: 1, Firstname, Lastname, 20 我想从这个mysql导入数据 person 表到配置单元表具有相同的结构,但仅来自表的第一列和最后一列 person . 因此,在导入之后,配置单元表中的行应该如下所示: 1, NULL, NULL, 20 我尝试了这个sqoop命令: sqoop import --connect jdbc:mysql://localhost:3306/lastdb --table person --username root --password pass --hive-import --hive-database lastdb --hive-table person --columns id,age 但它以以下格式将行导入配置单元表: 1, 20, NULL, NULL 谁能告诉我怎么修吗?

7cjasjjr

7cjasjjr1#

假设mysql表中的行 id, firstname, lastname, age 价值观: 1, NULL, NULL, 20, 然后,运行下面的sqoop导入脚本将在配置单元中提供所需的结果 person table。

~]$ sqoop import \
--connect \
jdbc:mysql://localhost:3306/lastdb \
--username=root \
--password=pass \
--query 'select * from person WHERE $CONDITIONS' \
--hive-import \
--hive-table person \
--hive-database lastdb \
--target-dir  /user/hive/warehouse/person -m 1

相关问题