麻豆小视频在线观看_中文黄色一级片_久久久成人精品_成片免费观看视频大全_午夜精品久久久久久久99热浪潮_成人一区二区三区四区

首頁 > 開發 > Java > 正文

hadoop入門之通過java代碼實現將本地文件上傳到hadoop的文件系統

2024-07-16 17:45:45
字體:
來源:轉載
供稿:網友

第一步:首先搭建java的編譯環境。創建一個Java Project工程,名為upload。

第二步:選中所需的Jar包。
選中JRE System Library 選擇BuildPath Configure Build Path 選擇hadoop相應的jar包。
通過Add External JARS --〉Hadoop-0.20.2下所有的jar包以及lib下所有的jar包。OK。操作步驟如圖:

Hadoop-0.20.2下所有的jar包。

lib下的所有jar包。

第三步:創建class名為UploadFile

第四步:編寫代碼。


復制代碼代碼如下:
package upload;</p><p>import java.io.BufferedInputStream;
import java.io.FileInputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.URI;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.IOUtils;</p><p>
public class UploadFile {</p><p> public static void main(String[] args) {
try {
String localStr = args[0];
String dst = args[1];
//in對應的是本地文件系統的目錄
InputStream in = new BufferedInputStream(new FileInputStream(localStr));
Configuration conf = new Configuration();
//獲得hadoop系統的連接
FileSystem fs = FileSystem.get(URI.create(dst),conf);

//out對應的是Hadoop文件系統中的目錄
OutputStream out = fs.create(new Path(dst));
IOUtils.copyBytes(in, out, 4096,true//4096是4k字節
System.out.println("success");
} catch (Exception e) {
System.out.println(e.toString());
}
}
}

第五步:在Run Configuration里面設置兩個參數,并執行。

點擊 Run Configuration

在Java Application中設置 Project和MainClass

Arguments 加兩個參數/home/cui/xxxx hdf://cui:9000/xxx Applay Run

第六步:查看結果。

顯示運行成功。

在hadoop文件系統中已經看到了hadoop-0.20.2.tar.gz了。

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 成人精品久久 | 精品中文字幕在线播放 | 在线区| 日韩毛片免费观看 | 精品国产一区二区三区天美传媒 | 国产精品免费麻豆入口 | 依依成人综合 | 国产午夜亚洲精品 | 逼片 | 国产精品久久久久久久久久 | 操碰视频在线观看 | 看免费的毛片 | 日韩视频区 | 日日鲁一鲁视频 | 在线播放免费人成毛片乱码 | 黄网站免费入口 | 黄色试看视频 | 欧美国产日韩在线 | 免费网址黄 | 蜜桃网在线观看 | 天堂在线中文资源 | 成人一级片毛片 | 精品国产一区二区三区四 | 亚洲视频高清 | 国产毛片毛片 | 色婷婷a v | 香蕉成人在线视频 | 91精品国产92久久久久 | 欧美国产精品久久 | 欧美a在线观看 | 精品国产九九九 | 新久草视频 | 欧洲精品视频在线观看 | 性少妇videosexfreexx入片 | 成年人免费黄色片 | 色偷偷欧美 | 久久欧美亚洲另类专区91大神 | 91精品久久久久久久 | 未成年人在线观看 | 成人在线视频免费 | 久久亚洲美女视频 |