次のコードスニペットを理解しようとしています。Sparkの基本的なメソッド呼び出しの理解
links.map{line => val fields = line.split(","); val f1 = x._1; (f1, "stuff)}
:私は、私はRDDのスパークマップ()関数を呼び出しに関してはイディオムの次のタイプを見慣れてい
val links = sc.textFile("../../data/links.csv")
val linksRDD: RDD[Edge[Connexion]] = links map {line =>
val row = line split ','
Edge(row(0).toInt, row(1).toInt, row(2))
}
...スパーク質問よりスカラ座のこの多くを考えます
私の質問は:私がこれまでのパターン以下を参照してください
val row = line split ','
すべて(非常に限られた)スパーク例:私は構造を理解することはできませんことを
val row = line.split(',')
私は基本的なSparkのチュートリアルを突き進んで、Scalaに行くために、私は何か基本的なものを見逃しているように感じます。
誰かが私が逃したことを教えてください...できますか?
おかげ
:
は同等ですあなたは正しいです@pedrofurlaこれは複製です。あなたがリンクした質問はおそらくより包括的に構成され、答えられます。 – markthekoala