直接上代码
val output = new Path("hdfs://master:9000/output/");
val hdfs = org.apache.hadoop.fs.FileSystem.get(
new java.net.URI("hdfs://master:9000"), new org.apache.hadoop.conf.Configuration())
// 删除输出目录
if (hdfs.exists(output)) hdfs.delete(output, true)
最后
以上就是会撒娇玉米最近收集整理的关于如何在spark中删除hdfs的某个文件夹的全部内容,更多相关如何在spark中删除hdfs内容请搜索靠谱客的其他文章。
本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
发表评论 取消回复