DStream [（Double、Double）]にmath.sqrtを使用するには？

Question

ストリーミングデータDStream[(Double, Double)]の場合、平均平方根誤差をどのように見積もりますか？以下の私のコードを見てください。

が

def calculateRMSE(output: DStream[(Double, Double)], n: DStream[Long]): Double = { 
     val summse = output.foreachRDD { rdd => 
      rdd.map { 
       case pair: (Double, Double) => 
       val err = math.abs(pair._1 - pair._2); 
       err*err 
      }.reduce(_ + _) 
     } 
     math.sqrt(summse) 
    } 

UPDATE： コードはコンパイルされない：Cannot resolve reference sqrt with such signature. Expected: Double, Actual: Unit

Answer 1

方法foreachRDD（...）はユニットをので返し線math.sqrt(summse)私は問題がある場合（コードはコンパイルされない）でありますそれは期待される。ドキュメントによると、結果はこの（出力）DStreamに書き戻されます。私はあなたがsqrtを適用する必要があると思う。