Hadoop_07_HDFS的Java API 操作

            package
             cn.bigdata.hdfs;

            import
             java.io.IOException;

            import
             java.net.URI;

            import
             java.net.URISyntaxException;

            import
             org.apache.hadoop.conf.Configuration;

            import
             org.apache.hadoop.fs.FileSystem;

            import
             org.apache.hadoop.fs.Path;

            import
             org.junit.Before;

            import
             org.junit.Test;

            /**
            
 * 客户端去操作HDFS时，是有一个用户身份的
 * 默认情况下，hdfs客户端api会从jvm中获取一个参数来作为自己的用户身份：-DHADOOP_USER_NAME=root
 * 也可以在构造客户端fs对象时，通过参数传递进去
 
            */
            public
            class
             HdfsCientDemo {
    
            private FileSystem fs  = null;
    Configuration conf = null;
    @Before
    publicvoid inin() throws IOException, InterruptedException, URISyntaxException{
        Configuration conf = new Configuration();
        //拿到一个文件系统操作的客户端实例对象,最后一个参数为用户名,nameNode访问路径：hdfs://shizhan2:9000
        fs = FileSystem.get(new URI("hdfs://shizhan2:9000"),conf,"root");
    }
    
    //上传文件    @Test
    publicvoid testUpload() throws Exception{
        fs.copyFromLocalFile(new Path("c:/regist.log"), new Path("/regist-copy.log"));
        fs.close();
    }
}

            
              @Test
    
            public
            void testDownload() throws Exception {
        fs.copyToLocalFile(false, new Path("/regist-copy.log"), new Path("D:/"), false);
        fs.close();
    }