在Scala中,作为一个实验,我使用Spark创建了一个序列文件,并将其读回来。我想删除该文件从塔奇扬使用火花脚本也。
val rdd = sc.parallelize(Array(("a",2), ("b",3), ("c",1)))
rdd.saveAsSequenceFile("tachyon://127.0.0.1:19998/files/123.sf2")
val rdd2 = sc.sequenceFile[String,Int]("tachyon://127.0.0.1:19998/files/123.sf2")我不太了解Scala语言,也找不到关于文件路径操作的参考。我确实找到了一种在Scala中使用Java来完成这个任务的方法,但我无法让它使用Tachyon。
import java.io._
new File("tachyon://127.0.0.1:19998/files/123.sf2").delete()发布于 2014-07-21 19:14:19
有不同的办法,例如:
更多信息:http://tachyon-project.org/Command-Line-Interface.html
https://stackoverflow.com/questions/24836253
复制相似问题