




下載本文檔
版權說明:本文檔由用戶提供并上傳,收益歸屬內(nèi)容提供方,若內(nèi)容存在侵權,請進行舉報或認領
文檔簡介
1、實驗1 HDFS Java API編程一、實驗目的1、理解HDFSB Hadoop體系結(jié)構(gòu)中的角色;2、熟悉HDFSt作常用的Java API。二、實驗平臺操作系統(tǒng):LinuxHadoop版本:或以上版本JDK版本:或以上版本Java IDE : Eclipse三、實驗內(nèi)容利用HDFS勺Java API編程實現(xiàn)以下指定功能:1、文件讀寫:通過FSDataOutputStream 將文件內(nèi)容寫入 HDFS通過FSDataInputStream從HDF計讀取文件內(nèi)容。Java代碼:package .*;public class MyTest1 public static void main(Str
2、ing口 args) throws IOException Configuration conf = new Configuration。;("","");("","");FileSystem fs = (conf);Path filePath = new Path("/user/hadoop/");public class MyTest2 public static boolean test(Configuration conf, String path)throws IOException
3、FileSystem fs = (conf);return (new Path(path);public static void copyFromLocalFile(Configuration conf,String localFilePath, String remoteFilePath) throws IOException FileSystem fs = (conf);Path localPath = new Path(localFilePath);Path remotePath = new Path(remoteFilePath);/*第一個參數(shù)表示是否刪除源文件,第二個參數(shù)表示是否覆
4、蓋*/(false, true, localPath, remotePath);();public static void appendToFile(Configuration conf, String localFilePath,String remoteFilePath) throws IOException FileSystem fs = (conf);Path remotePath = new Path(remoteFilePath);/*創(chuàng)建一個文件讀入流*/FileInputStream in = new FilelnputStream(localFilePath);/*創(chuàng)建一個文
5、件輸出流,輸出的內(nèi)容將追加到文件末尾*/FSDataOutputStream out = (remotePath);/*讀寫文件內(nèi)容*/byte口 data = new byte1024;int read = -1;while (read = (data) > 0) (data, 0, read);();();();public static void main(String口 args) Configuration conf = new Configuration。;("","");("","");(&qu
6、ot;", "NEVER");("", "true");String localFilePath = "/home/hadoop/" else + " 不存在.");/*進行處理*/if (!fileExists) 5public class MyTest3 /*下載文件到本地判斷本地路徑是否已存在,若已存在,則自動進行重命名*/public static void copyToLocal(Configuration conf, String remoteFilePath,String
7、 localFilePath) throws IOException FileSystem fs = (conf);Path remotePath = new Path(remoteFilePath);File f = new File(localFilePath);/*如果文件名存在,自動重命名(在文件名后面加上 _0, _1)*/if () + " 已存在.");Integer i = 0;while (true) f = new File(localFilePath + "_" + ();if (!() localFilePath = localF
8、ilePath + "_" + ();break;i+;"將重新命名為:"+ localFilePath);public class MyTest4 /*讀取文件內(nèi)容*/public static void cat(Configuration conf, String remoteFilePath)throws IOException FileSystem fs = (conf);Path remotePath = new Path(remoteFilePath);FSDataInputStream in = (remotePath);BufferedR
9、eader d = new BufferedReader(new InputStreamReader(in);String line = null;while (line = () != null) ();();();public static void main(String口 args) Configuration conf = new Configuration。;("","");String remoteFilePath = "/user/hadoop/"public class MyTest5 /*刪除文件*/public
10、static boolean rm(Configuration conf, String remoteFilePath)throws IOException FileSystem fs = (conf);Path remotePath = new Path(remoteFilePath);boolean result = (remotePath, false);();return result;public static void main(String口 args) Configuration conf = new Configuration。;("","");String remoteFilePath = "/user/hadoop/&
溫馨提示
- 1. 本站所有資源如無特殊說明,都需要本地電腦安裝OFFICE2007和PDF閱讀器。圖紙軟件為CAD,CAXA,PROE,UG,SolidWorks等.壓縮文件請下載最新的WinRAR軟件解壓。
- 2. 本站的文檔不包含任何第三方提供的附件圖紙等,如果需要附件,請聯(lián)系上傳者。文件的所有權益歸上傳用戶所有。
- 3. 本站RAR壓縮包中若帶圖紙,網(wǎng)頁內(nèi)容里面會有圖紙預覽,若沒有圖紙預覽就沒有圖紙。
- 4. 未經(jīng)權益所有人同意不得將文件中的內(nèi)容挪作商業(yè)或盈利用途。
- 5. 人人文庫網(wǎng)僅提供信息存儲空間,僅對用戶上傳內(nèi)容的表現(xiàn)方式做保護處理,對用戶上傳分享的文檔內(nèi)容本身不做任何修改或編輯,并不能對任何下載內(nèi)容負責。
- 6. 下載文件中如有侵權或不適當內(nèi)容,請與我們聯(lián)系,我們立即糾正。
- 7. 本站不保證下載資源的準確性、安全性和完整性, 同時也不承擔用戶因使用這些下載資源對自己和他人造成任何形式的傷害或損失。
最新文檔
- DB32/T 3883-2020心肺運動測試儀呼吸系統(tǒng)通用測試規(guī)范
- DB32/T 3761.32-2021新型冠狀病毒肺炎疫情防控技術規(guī)范第32部分:無疫小區(qū)建設
- DB32/T 3731-2020信訪“人民滿意窗口”創(chuàng)建規(guī)范
- DB32/T 3631-2019沿海灘涂鹽堿地菊芋栽培技術規(guī)程
- DB32/T 3577-2019農(nóng)村產(chǎn)權交易服務通則
- DB32/T 3548-2019醫(yī)療機構(gòu)醫(yī)療廢物在線追溯管理信息系統(tǒng)建設指南
- DB31/T 986-2016水蜜桃冷鏈物流技術規(guī)程
- DB31/T 910-2015區(qū)域雷擊風險評估技術規(guī)范
- DB31/T 527-2020醫(yī)用電子加速器治療機房放射防護與檢測要求
- DB31/T 1323-2021航空航天用壓力傳感器動態(tài)測試方法
- 高等數(shù)學(慕課版)教案 教學設計-5.4 定積分的應用;5.5 反常積分
- 車載感知與融合算法-深度研究
- 乙狀結(jié)腸癌相關知識
- 《鼴鼠的月亮河》閱讀測試題及答案
- 醫(yī)學生青年紅色筑夢之旅項目計劃書
- 金融學科研究新高度:黃達《金融學》2025課件解讀
- 遼寧省沈陽市2025年高中三年級教學質(zhì)量監(jiān)測(一)地理試題(含答案)
- 2025年東莞市長安鎮(zhèn)事業(yè)單位招考工作人員高頻重點提升(共500題)附帶答案詳解
- 鋼箱梁加工制作及安裝方案
- 鐵路貨物運價規(guī)則
- 2024版園林景觀工程建設項目招投標代理合同3篇
評論
0/150
提交評論