博客

String hiveIP = "hdfs://ip:端口号";
Configuration config = new Configuration();
            config.set("fs.defaultFS",hiveIP);
            config.set("fs.hdfs.impl",org.apache.hadoop.hdfs.DistributedFileSystem.class.getName());
            fs = FileSystem.get(config);
              FileStatus[] statuses = fs.listStatus(new Path("文件夹地址"));
      for (FileStatus status : statuses) {
                    boolean delete = fs.delete(status.getPath(), true);//删除
                }