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