我是 Spark 編程的新手。我正在嘗試從 RDD 中提取值，因為我從 RDD 獲得了以下輸出
(CBI10006,(Some(Himanshu Vasani),None))
(CBI10004,(Some(Sonam Petro),Some(8500)))
(CBI10003,(None,Some(3000)))
我想將以上值提取到低于 1
(CBI10006,Himanshu Vasani,'')
(CBI10004,Sonam Petro,8500)
(CBI10003,'',3000)
我已經嘗試過 FlatMap 方法如下
joined.flatMap{case(f1,f2) => (f1,(f2._1,f2._2))} but getting a below error
type mismatch;
found : (String, (Option[String], Option[String]))
required: TraversableOnce[?]
**joined.flatMap{case(f1,f2) => (f1,(f2._1,f2._2))}**
uj5u.com熱心網友回復：
使用map()：
val data = Seq(("CBI10006", (Some("Himanshu Vasani"), None)), ("CBI10004", (Some("Sonam Petro"), Some(8500))),
("CBI10003", (None, Some(3000))))
spark.sparkContext
.parallelize(data)
.map { case (x, y) => (x, y._1.getOrElse(""), y._2.getOrElse("")) }
.foreach(println)
// output:
// (CBI10006,Himanshu Vasani,)
// (CBI10004,Sonam Petro,8500)
// (CBI10003,,3000)
轉載請註明出處，本文鏈接：https://www.uj5u.com/net/403825.html
標籤：