将查询结果从关系数据库导入 HDFS
在导入操作中可以使用查询代替表:
sqoop import --query 'select Id,Message from TestTable where $CONDITIONS'
--where 'id>100'
--connect "jdbc:sqlserver://192.168.1.100:1433;database=Test_db
--username user
-–password password
--split-by id
--target-dir /user/test/
--fields-terminated-by '\t'
- 其中$ CONDITIONS - 即使条件不存在也是强制性的
- split-by - mandatory,指定拆分操作的列。用于在导入 MapReduce 作业中拆分任务