HDFS文件下载

  1 //文件下载
  2 @Test
  3 	public void testCopyToLocalFile() throws IOException,InterruptedException,URISyntaxException{
  4 
  5 		//1.获取文件系统
  6 		Configuration configuration = new Configuration();
  7 		FileSystem fs = FileSystem.get(new URI("hdfs://192.168.12.161:9000"), configuration, "hadoop");
  8 		//2.执行下载操作
  9 		//boolean delSrc 指是否将原文件删除
 10 		//Path src 值要下载的文件路径
 11 		//Path dst 指将文件下载到的路径
 12 		//boolean useRawLocalFileSystem 是否开启文件校验
 13 		fs.copyToLocalFile(false, new Path("/qiuyun.txt"),new Path("d:/Hadoop/HDFS/nanzhou.txt"));
 14 		//3.关闭资源
 15 		fs.close();
 16 	}