Sqoop

sqoop使用:
  • 根據(jù)腳本執(zhí)行:sqoop --options-file sqoop.sh

import
--connect
"'jdbc:sqlserver://[url]:[port];DatabaseName=[database];user=[user];password=[password]"
--driver
com.mysql.jdbc.Driver
--query
"SELECT id, name FROM sqoop_test WHERE $CONDITIONS"
--hbase-table
sqoop_table
--column-family
cf1
--hbase-row-key
id
--split-by
id
-m
8

  • sqoop運(yùn)行提示Class Not Found,將需要的jar放到/opt/cloudera/parcels/CDH-5.15.1-1.cdh5.15.1.p0.4/lib/sqoop/lib下面

  • 直接命令執(zhí)行 sqoop import --connect 'jdbc:sqlserver://[url]:[port];DatabaseName=[database];user=[user];password=[password]' --driver com.microsoft.sqlserver.jdbc.SQLServerDriver --query "SELECT id,status,updateTime FROM dbo.discovery WHERE updateTime > '$1' and \$CONDITIONS" --hbase-table discovery --hbase-create-table --column-family cf1 --hbase-row-key id --split-by id -m 8

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡書系信息發(fā)布平臺(tái),僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容