上傳檔案到HDFS方式

2021-07-01 18:11:14 字數 1059 閱讀 7266

hadoop計算需要在hdfs檔案系統上進行,因此每次計算之前必須把需要用到的檔案(我們稱為原始檔案)都上傳到hdfs上。檔案上傳到hdfs上通常有三種方法:

1、 hadoop自帶的dfs服務,put;

2、 hadoop的api,writer物件可以實現這一功能;

3、 呼叫otl可執行程式,資料從資料庫直接進入hadoop

將1、2方案進行對比,如下:

1 空間:方案1在hdfs上占用空間同本地,因此假設只上傳日誌檔案,則儲存乙個月日誌檔案將消耗掉約10t空間,如果加上這期間的各種維表、事實表,將占用大約25t空間

方案2經測試,壓縮比大約為3~4:1,因此假設hdfs空間為100t,原來只能儲存約4個月的資料,現在可以儲存約1年

2 上傳時間:方案1的上傳時間經測試,200g資料上傳約1小時

方案2的上傳時間,程式不做任何優化,大約是以上的4~6倍,但存在一定程度提公升速度的餘地

3 運算時間:經過對200g資料,大約4億條記錄的測試,如果程式以io操作為主,則壓縮資料的計算可以提高大約50%的速度,但如果程式以記憶體操作為主,則只能提高5%~10%的速度

4 其它:未壓縮的資料還有乙個好處是可以直接在hdfs上檢視原始資料。壓縮資料想看原始資料只能用程式把它導到本地,或者利用本地備份資料

壓縮格式:按照hadoop api的介紹,壓縮格式分兩種:block和record,其中record是只對value進行壓縮,一般採用block進行壓縮。

對壓縮檔案進行計算,需要用sequencefileinputformat類來讀入壓縮檔案,以下是計算程式的典型配置**:

jobconf conf = new jobconf(getconf(), log.class);

conf.setjobname(」log」);

conf.setoutputkeyclass(text.class);//set the map output key type

conf.setoutputvalueclass(text.class);//set the map output value type

接下來的處理與非壓縮格式的處理一樣

本文出自:

上傳檔案到HDFS

hadoop計算需要在hdfs檔案系統上進行,檔案上傳到hdfs上通常有三種方法 a hadoop自帶的dfs服務,put b hadoop的api,writer物件可以實現這一功能 c 呼叫otl可執行程式,資料從資料庫直接進入hadoop hadoop計算需要在hdfs檔案系統上進行,因此每次計...

Linux上傳本地檔案到HDFS

su hdfs 切換到hdfs使用者 cd home hdfs files 進入到伺服器中檔案所在目錄 ls 檢視此目錄下的檔案列表vim test.txt 若檔案存在可顯示檔案中的內容,若不存在則新建檔案 test.txt檔案中的內容 1 15673830092 aaa 2 15837287388...

上傳檔案到hdfs注意事項

我在mapreduceinput下建立cfitemset資料夾,下面有itemset.txt。我想上傳到cf下,然後想著hdfs上會顯示cf itemset.txt。hdfs dfs put itemset.txt cf 但是發現hdfs上只有cf檔案,注意並不是資料夾,好奇怪,只能先刪除 否則提示...