sqoop增量匯入

2021-10-10 09:01:10 字數 612 閱讀 9114

執行以下指令先將我們之前的資料匯入

sqoop import \

--connect jdbc:mysql://master:3306/test \

--username hive \

--password 123456 \

--table customer \

-m 1

使用hdfs dfs -cat檢視生成的資料檔案,發現資料已經匯入.然後我們在mysql的customer中插入2條資料

insert into customer values(6,'james');

insert into customer values(7,'luna');

執行如下的指令,實現增量的匯入

sqoop import \

--connect jdbc:mysql://master:3306/test \

--username hive \

--password 123456 \

--table customer \

--check-column id \

--

sqoop 增量匯入

在隨著系統的執行,每天都會產生新的資料,在進行資料匯入的時候,由於之前已經匯入過資料,所以在產生新的資料的時候,就可以直接在之前導過的資料的基礎上繼續匯入資料,沒有必要之前的所有資料都重新匯入一遍 增量匯入資料的使用 以上為增量匯入的引數check column 檢查列,檢查資料庫表中的索引列,一般...

sqoop增量資料匯入

1.使用sqoop按欄位增長將mysql中資料抽取到hdfs 2.使用sqoop按時間增長將mysql中資料抽取到hdfs jps start all.sh2.開啟mysql服務。sudo service mysql start登入mysql mysql u root p3.在mysql庫中,建立s...

Sqoop增量資料匯入

1.掌握sqoop的時間增量抽取 2.掌握sqoop的字段增量抽取 sqoop會抽取buyer id大於10005的資料。2 lastmodified模式是根據時間作為標準,比如 incremental lastmodified check column reg date last value 20...