我有一个 RDD，如下所示：
uidProcessedKeywords: org.apache.spark.rdd.RDD[(Long, Map[String,Double])]
如何展平 RDD 中的地图以获得以下结果：
org.apache.spark.rdd.RDD[(Long, String, Double)]
val x = sc.parallelize(List((2, Map("a" -> 0.2, "b" -> 0.3))))
x.flatMap {
case (id, m) => m.map { case (k, v) => (id, k, v)}
}
.collect()
res1: Array[(Int, String, Double)] = Array((2,a,0.2), (2,b,0.3))
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
