Hadoop學習--通過API上傳文件--day04

import java.io.BufferedInputStream;

公司主營業(yè)務：成都網站設計、網站建設、外貿網站建設、移動網站開發(fā)等業(yè)務。幫助企業(yè)客戶真正實現(xiàn)互聯(lián)網宣傳，提高企業(yè)的競爭能力。成都創(chuàng)新互聯(lián)是一支青春激揚、勤奮敬業(yè)、活力青春激揚、勤奮敬業(yè)、活力澎湃、和諧高效的團隊。公司秉承以“開放、自由、嚴謹、自律”為核心的企業(yè)文化，感謝他們對我們的高要求，感謝他們從不同領域給我們帶來的挑戰(zhàn)，讓我們激情的團隊有機會用頭腦與智慧不斷的給客戶帶來驚喜。成都創(chuàng)新互聯(lián)推出句容免費做網站回饋大家。

import java.io.BufferedOutputStream;

import java.io.ByteArrayOutputStream;

import java.io.FileInputStream;

import java.io.InputStream;

import java.net.URL;

import org.apache.hadoop.conf.Configuration;

import org.apache.hadoop.fs.FSDataInputStream;

import org.apache.hadoop.fs.FSDataOutputStream;

import org.apache.hadoop.fs.FileSystem;

import org.apache.hadoop.fs.FsUrlStreamHandlerFactory;

import org.apache.hadoop.fs.Path;

import org.apache.hadoop.io.IOUtils;

import org.junit.Test;

/**

 * 通過API實現(xiàn)文件上傳

 * @author Administrator

 *

 */

public class putfile {

/**

* 通過API上傳數(shù)據

* 

* @author Administrator

* 

* [hadoop@hadoop01 ~]$ hdfs dfs -chmod -R a+w /user/hadoop

* [hadoop@hadoop01 ~]$ hdfs dfs -ls -R /

*

* 

*/

@Test

public void putFile() throws Exception {

//創(chuàng)建configuration對象，有個默認的加載順序，先從core-default.xml，再到src目錄中的文件,這里

//我們給定了

        Configuration conf = new Configuration();

//通過conf的configuration對象創(chuàng)建了該分布式文件系統(tǒng)fs，默認如果不指定文件的話為本地文件系統(tǒng)

        FileSystem fs = FileSystem.get(conf);

        //定義一個URL的字符串,上傳文件的目錄

        String file = "hdfs://hadoop01:9000/user/hadoop/data2/shengfenzhao.jpg";

        //通過一個URL的字符串構建一個path對象

        Path path = new Path(file);

        FSDataOutputStream out = fs.create(path);

        IOUtils.copyBytes(new FileInputStream("E:/zhaopian.jpg"), out, 1024);

        //其他方法一

//        byte[] bys = new byte[1024];

//        int len = 0;

//        while((len = (new FileInputStream("E:/zhaopian.jpg")).read(bys)) !=-1) {

//        out.write(bys, 0, len);

//        }

        //其他方法二

//        BufferedInputStream bis = new BufferedInputStream(new FileInputStream("E:/zhaopian.jpg"));

//        BufferedOutputStream bos = new BufferedOutputStream(out);

//        int len =0;

//        while((len=bis.read())!=-1){

//        bos.write(len);

//        }

   }

}

當前題目：Hadoop學習--通過API上傳文件--day04
本文URL：http://muchs.cn/article22/geohjc.html

成都網站建設公司_創(chuàng)新互聯(lián)，為您提供域名注冊、建站公司、網站改版、營銷型網站建設、定制開發(fā)、網站排名

廣告

聲明：本網站發(fā)布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)