HDFS文件和文件夹判断

  1 @Test
  2 public void testListStatus() throws IOException, InterruptedException, URISyntaxException {
  3 
  4 	//获取文件配置信息
  5 	Configuration configuration = new Configuration();
  6 	FileSystem fs = FileSystem.get(new URI("hdfs://192.168.12.161:9000"), configuration, "hadoop");
  7 	//判断是文件还是文件夹
  8 	FileStatus[] lisFileStatus = fs.listStatus(new Path("/"));
  9 	for (FileStatus fileStatus : lisFileStatus) {
 10 		//如果是文件
 11 		if (fileStatus.isFile()) {
 12 			System.out.println("文件:"+fileStatus.getPath().getName());
 13 		} else {
 14 			System.out.println("文件夹:"+fileStatus.getPath().getName());
 15 		}
 16 	}
 17 	//关闭资源
 18 	fs.close();
 19 }