將查詢結果從關聯式資料庫匯入 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 作業中拆分任務