我想在运行spark作业时创建底层HDFS的快照。特定步骤涉及删除某些Parquet文件的内容。我想创建快照执行删除操作，验证操作结果并继续执行后续步骤。但是，我找不到从我的spark作业访问HDFSAPI的好方法。我要创建快照的目录在HDFS中被标记/标记为可快照。创建快照的命令行方法有效，但是我需要以编程方式执行此操作。我在CDH5.5上运行Spark1.5。关于如何执行此操作的任何提示线索？谢谢内存开发 最佳答案 我还没有验证这一点，但至少我没有遇到编译错误，理论上这个解决方案应该有效。这是Scala代码:valsc=newS