Scala - Spark：結果をファイルに保存

Question

Scala APIを使用してSparkでシーケンスモデルを実行しています。

model.freqSequences.collect().foreach { freqSequence => println(freqSequence.sequence.map(_.mkString("[", ", ", "]")).mkString("[", ", ", "]") + ", " + freqSequence.freq)} 

問題は結果が大きくなっていると（コレクト使用したくない）もうなく、どちらかHDFSまたはローカルでファイルに保存している：これは、結果を参照するには、コードの行です。私はこれを試しました：

scala> val outcome = model.freqSequences.foreach { freqSequence => println(freqSequence.sequence.map(_.mkString("[", ", ", "]")).mkString("[", ", ", "]") + ", " + freqSequence.freq)} 

scala> outcome.saveAsTextFile("tmp/outcome1/") 

error: saveAsTextFile is not a member of Unit 

結果はユニットであり、私はsaveAsTextFileを使用することができません。この結果を保存するための他の方法はありますか？ Txs。

Answer 1

foreachは、Unitを返します。

最初にmap〜Stringにしたいので、ファイルとして保存することができます。何かのように：[将来の使用のために保存MLモデル]の

val outcome = model.freqSequences.map { freqSequence => freqSequence.sequence.map(_.mkString("[", ", ", "]")).mkString("[", ", ", "]") + ", " + freqSequence.freq} 
// print 
outcome.foreach(println) 
// save 
outcome.saveAsTextFile("tmp/outcome1/")