val updateFunc2 = (iter:Iterator[(String,Seq[Int],Option[Int])])=>{iter.map{case (x,y,z) =>//由于Some的get方法得到的還是一個Some.所以這里要在用一個get方法//,如果最開始的時候用的時flatmap那么這里就不用調用get方法,這里可以推測出FlatMap會把Some中的元素取出來Some(y.sum+z.getOrElse(0)).map(i=>(x,i)).get}// iter.flatMap { case (x, y, z) => Some(y.sum + z.getOrElse(0)).map(i => (x, i)) }}

?

總結

以上是生活随笔為你收集整理的sparkStreaming 练习的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。