将查询结果从关系数据库导入 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 作业中拆分任务