スパークScalaの問題

Question

は "Scalaは" と言います。

しかし：

val l = "Scala" 
myRdd.map(line => if (line.split(" ").contain(l)) {(l, 1)}) 

が動作しない、それはエラーなしでプログラムをフリーズします。

ローカル変数が原因であるようですが、理由を把握できません。

Answer 1

おかげジャスパー-M、

final val lang_i 

はうまく働きました。しかし、私はこれが少なくとも私がやったすべての検索から良く知られていないことに非常に驚いています。

final val langs = List("Java", "Scala", "Python") 
wikiRdd.flatMap(wa => langs.map(lang => if(wa.split(" ").contain(lang)) {(lang, 1)})) 

しかし、最終does'tは、リストのために働くように見える：

私は動作しません（構文がわからない）、次のような何かを実際にしたいと思います。私は提供されたリンクを詳しく見ていきますが、直接的な答えは私の苦痛をかなり緩和します。

私の知らないことにも申し訳ありませんが、私はラムダ式で変数を渡さずにリファクタリングやコードの記述方法がわからないという点で、「スカラ」の答えにも興味があります。私はまだ学んでいます...しかし、私はこのリストの例がどのように解決できるかを知りたいのです。

感謝の

イージー