5

Scala では、実験として、Spark を使用して Tachyon でシーケンス ファイルを作成し、それを読み戻します。また、Spark スクリプトを使用して Tachyon からファイルを削除したいと考えています。

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()
4

1 に答える 1

-1

さまざまなアプローチがあります。たとえば、次のとおりです。

  • CLI:

    ./bin/tachyon tfs rm filePath

詳細: http://tachyon-project.org/Command-Line-Interface.html

  • API:

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

詳細: https://github.com/amplab/tachyon/blob/master/core/src/main/java/tachyon/examples/BasicOperations.java

于 2014-07-21T19:14:19.930 に答える