hadoop 学习（四）之java操作hdfs

            static FileSystem  fs=null;
    publicstaticvoid main(String[] args) throws Exception {
        // TODO Auto-generated method stub        init();        
        testUpload();
    }
    
    
    publicstaticvoid init() throws Exception{
        fs=FileSystem.get(new URI("hdfs://192.168.1.7:9000"), new  Configuration(),"hadoop");
        
    }
    
    /**
     * 将本地文件复制到hdfs文件系统里面
     * @throws Exception
     * @throws IOException
     */publicstaticvoid testUpload() throws Exception, IOException{
        OutputStream remote= fs.create(new Path("/uploadjdk"));
        FileInputStream local=new FileInputStream("c://jdk.rar");
        IOUtils.copyBytes(local, remote,4096,true);
    }
    
    /**
     * 从hdfs文件系统里面下载文件 
     * @throws Exception
     * @throws IOException
     */publicvoid testDownload() throws Exception, IOException{
        InputStream in= fs.open(new Path("/eclipse-SDK-4.3.1-linux-gtk-x86_64.tar.gz"));
        OutputStream output=new FileOutputStream("c://jdk2.rar");
        IOUtils.copyBytes(in, output,4096,true);
    }