Apache Spark-Scala-HashMap(k，HashMap [String，Double](v1，v2，..))到((k，v1)，(k，v2)，...) [英] Apache Spark - Scala - HashMap (k, HashMap[String, Double](v1, v2,..)) to ((k,v1),(k,v2),…)
本文介绍了Apache Spark-Scala-HashMap(k，HashMap [String，Double](v1，v2，..))到((k，v1)，(k，v2)，...)的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！
问题描述
我得到了:
val vector: RDD[(String, HashMap[String,Double])] = [("a", {("x",1.0),("y", 2.0),...}]
我想得到:
RDD[String,(String,Double)] = [("a",("x",1.0)), ("a", ("y", 2.0)), ...]
如何使用FlatMap完成?欢迎提供更好的解决方案！
How can it be done with FlatMap? Better solutions are welcome!
推荐答案
尝试:
vector.flatMapValues(_.toSeq)
这篇关于Apache Spark-Scala-HashMap(k，HashMap [String，Double](v1，v2，..))到((k，v1)，(k，v2)，...)的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！
查看全文
