Hadoop Java 程序2：复制本地文件（包括目录）到 HDFS

import org.apache.hadoop.conf.Configuration;

import org.apache.hadoop.fs.FileSystem;

import org.apache.hadoop.fs.Path;

import java.net.URI;

public class DirectoryCopyWithProgress {

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

        String localSrc = args[0];

        String dst = args[1];

        Configuration conf = new Configuration();

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

        fs.copyFromLocalFile(false,true, new Path(localSrc), new Path(dst));

    }

}

export HADOOP_CLASSPATH=/home/hadoop/sandbox

$ hadoop DirectoryCopyWithProgress testdata/ /

$ hadoop DirectoryCopyWithProgress testdata/ hdfs://192.168.1.150:9000/