Sqoop將資料從Mysql匯入Hive中

2021-08-11 15:03:00 字數 919 閱讀 8490

hive匯入引數

--hive-home 重寫$hive_home

--hive-import 插入資料到hive當中,使用hive的預設分隔符

--hive-overwrite 重寫插入

--create-hive-table 建表,如果表已經存在,該操作會報錯!

--hive-table [table] 設定到hive當中的表名

--hive-drop-import-delims 匯入到hive時刪除 \n, \r, and \01

--hive-delims-replacement 匯入到hive時用自定義的字元替換掉 \n, \r, and \01

--hive-partition-key hive分割槽的key

--hive-partition-value hive分割槽的值

--map-column-hive 型別匹配,sql型別對應到hive型別

sqoop import \

--connect "jdbc:mysql://localhost:3306/managdb?useunicode=true&characterencoding=utf-8" --username xx --password ***x\

--query "select p from tb where \$conditions;" -m 1 \

--null-string 'null' --null-non-string 'null' \

--fields-terminated-by ',' --lines-terminated-by '\n' \

--hive-drop-import-delims \

--target-dir /usr/local/data --as-textfile \

--delete-target-dir;

使用sqoop將mysql資料匯入hbase

下表 1 通過hbase shell 開啟hbase。2 建立乙個hbase表 3 將so表的資料匯入到hbase中。opt檔案 connect 資料庫 username 資料庫使用者名稱 password 資料庫密碼 table 需要sqoop的表 columns 表中的列 hbase table...

利用Sqoop將MySQL資料匯入Hive中

參考 1.list databases sqoop list databases connect jdbc mysql username sqoop password sqoop 2.用sqoop建立hive表 sqoop create hive table connect jdbc mysql x...

Sqoop將Mysql資料同步到Hbase

1 首先進入hbase中建立一張表 bin hbase shell create alarm info1 表名 alarm 列簇 info1 2 進入sqoop的bin目錄下執行 sqoop import connect jdbc mysql table alarm hbase table alar...