タイプSeq [ユニット]の式がスケーラのSeq [DataFrame]に一致しません

Question

私の機能では、データフレームのシーケンスfinalDFを返します。下のループではmapはSeq[DataFrame]を返し、finalDFに保存されているので、処理がさらに進む場合がありますが、フィルタ処理されたデータフレームを各繰り返しに保存して次のループ。

どうすればよいですか？それをある一時的な値に代入しようとすると、タイプSeq[unit]の式が期待されるタイプSeq[DataFrame]に適合しないというエラーがスローされます。

var finalDF: Seq[DataFrame] =null 

    for (i <- 0 until stop){ 
    finalDF=strataCount(i).map(x=> { 
    df.filter(df(cols(i)) === x) 

    //how to get the above data frame to pass on to the next computation? 
    } 
) 

} 

よろしく

Answer 1

多分これは便利です：

val finalDF: Seq[DataFrame] = (0 to stop).flatMap(i => strataCount(i).map(x => df.filter(df(cols(i)) === x))).toSeq 

flatMapSeq(Seq)を平らにします。

(0 to stop).flatMap(j => { 
(0 to stop).flatMap(i => strataCount(i).map(x => df.filter(df(cols(i)) === x))) 
}).toSeq 

たりしてみてくださいを：：for yield、参照多分あなたが好きそれを行うことができ、2つのカウンタの

scala> (0 to 20).flatMap(i => List(i)) 
res0: scala.collection.immutable.IndexedSeq[Int] = Vector(0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20) 
scala> (0 to 20).map(i => List(i)).flatten 
res1: scala.collection.immutable.IndexedSeq[Int] = Vector(0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20) 

：

(0 to stop)0からstopにループ、flatMapはList、同様に平らになります：Scala for/yield syntax