package com.yoyosys.cebbank.bdap.service.mr;

import java.io.BufferedInputStream;

import java.io.FileInputStream;

import java.io.IOException;

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;

/**

 * 将本地文件复制到hadoop文件系统

 * @author Administrator

 *

 */

public class FileSystemCat {

    public static void main(String[] args) throws IOException {

        String localsrc = args[0];

        String dst = args[1];

        InputStream in = new BufferedInputStream(new FileInputStream(localsrc));

        Configuration conf = new Configuration();

        FileSystem fs = FileSystem.get(URI.create(dst),conf);

        OutputStream out = fs.create(new Path(dst));

        IOUtils.copyBytes(in, out,4096, true);//true代表是否执行完关闭数据流

    }

}