本篇文章為大家展示了JAVA API怎樣進行讀寫HDFS,內(nèi)容簡明扼要并且容易理解,絕對能使你眼前一亮,通過這篇文章的詳細介紹希望你能有所收獲。
成都創(chuàng)新互聯(lián)公司是一家專注于成都網(wǎng)站制作、做網(wǎng)站與策劃設計,長白網(wǎng)站建設哪家好?成都創(chuàng)新互聯(lián)公司做網(wǎng)站,專注于網(wǎng)站建設十多年,網(wǎng)設計領域的專業(yè)建站公司;建站業(yè)務涵蓋:長白等地區(qū)。長白做網(wǎng)站價格咨詢:028-86922220
package demo; import java.io.IOException; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FSDataInputStream; import org.apache.hadoop.fs.FSDataOutputStream; import org.apache.hadoop.fs.FileStatus; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; public class PutMerge { public static void main(String[] args) throws IOException{ Configuration conf=new Configuration(); FileSystem hdfs=FileSystem.get(conf); FileSystem local=FileSystem.getLocal(conf); //設定輸入目錄于輸出文件 Path inputDir=new Path(args[0]); Path hdfsFile=new Path(args[1]); //得到本地文件列表 FileStatus[] inputFiles=local.listStatus(inputDir); //生成HDFS輸出流 FSDataOutputStream out=hdfs.create(hdfsFile); for(int i=0;i0){ out.write(buffer,0,bytesRead); } in.close(); } out.close(); } }
上述內(nèi)容就是JAVA API怎樣進行讀寫HDFS,你們學到知識或技能了嗎?如果還想學到更多技能或者豐富自己的知識儲備,歡迎關注創(chuàng)新互聯(lián)行業(yè)資訊頻道。