hadop 자바 API 파일 업로드 실현

2998 단어 hadoop
package com.zlf;

import java.io.FileInputStream;
import java.io.IOException;

import org.apache.commons.io.IOUtils;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FSDataOutputStream;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;


public class Demo {

    public static void main(String[] args) throws IOException {
        // TODO Auto-generated method stub
        Configuration conf=new Configuration();

        conf.set("fs.defaultFS", "hdfs://localhost:9000");

        FileSystem fs=FileSystem.get(conf);

        FSDataOutputStream fsDataOutputStream=fs.create(new Path("/RoseHA.rar"));

        FileInputStream fileInputStream=new FileInputStream("d:/RoseHA.rar");

        IOUtils.copy(fileInputStream, fsDataOutputStream);


    }

}

다음은 또 다른 실현 방식 으로 매우 간단 하 다.
//          
fs.copyFromLocalFile(new Path("d:/PowerDesigner15_Evaluation.rar"), new Path("/PowerDesigner15_Evaluation.rar"));

좋은 웹페이지 즐겨찾기