将本地文件复制到复制到Hadoop文件系统

时间：2015-02-22 23:10:25 阅读：437 评论：0 收藏：0 [点我收藏+]

标签：

//将本地文件复制到复制到Hadoop文件系统
//目前，其他Hadoop文件系统写入文件时均不调用progress()方法。
package com;

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;
import org.apache.hadoop.util.Progressable;

public class FileCopyWithProgress {
public static void main(String[] args) throws Exception{
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), new Progressable(){
public void progress(){
System.out.println(".");
}
});

IOUtils.copyBytes(in, out, 4096, true);

}
}

标签：

原文地址：http://blog.csdn.net/u012965373/article/details/43909775

踩

(0)

评论一句话评论（0）

分享档案

更多>

2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)

周排行