Spark Tachyon: Dosya nasıl silinir?

Question

Scala'da, bir deneme olarak Spark kullanarak Tachyon'da bir sıra dosyası oluşturup onu tekrar okuyun. Bu dosyayı da Spark komutunu kullanarak Tachyon'dan silmek istiyorum.

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 dilini çok iyi anlamıyorum ve dosya yolu işleme hakkında bir başvuru bulamıyorum. Bunu yapmak için bir şekilde Java'yı Scala'da kullanmanın bir yolunu buldum, ancak Tachyon'u kullanarak çalışamıyorum.

./bin/tachyon tfs rm filePath 

diğer bilgiler: http://tachyon-project.org/Command-Line-Interface.html

• import java.io._ 
  new File("tachyon://127.0.0.1:19998/files/123.sf2").delete() 
  

Answer 1

farklı yaklaşım, ör .:

• CLI vardırAPI:

  TachyonFS sTachyonClient = TachyonFS.get(args[0]); 
  sTachyonClient.delete(filePath, true); 
  

diğer bilgiler: Ben oluşturduğum tüm dosyaları silerek kullandıktan sonra bir dosya yolu temizlemek için çalıştı benzer bir sorun yaşadım https://github.com/amplab/tachyon/blob/master/core/src/main/java/tachyon/examples/BasicOperations.java