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;

import org.apache.hadoop.util.Progressable;

public class FileCopyWithProcess {

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

        // TODO Auto-generated method stub

        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);

        try {

            OutputStream out = fs.create(new Path(dst),new Progressable() {

                @Override

                public void progress() {

                    // TODO Auto-generated method stub

                    System.out.println(".");

                }

            });

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

        } catch (IOException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        }

    }

}

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