Apache Spark - Scala - HashMap (k, HashMap [String, Double] (v1, v2, ..)) bis ((k, v1), (k, v2), ...)

Question

Ich habe:

val vector: RDD[(String, HashMap[String,Double])] = [("a", {("x",1.0),("y", 2.0),...}] 

ich möchte zu bekommen:

RDD[String,(String,Double)] = [("a",("x",1.0)), ("a", ("y", 2.0)), ...] 

Wie kann es mit FlatMap getan werden? Bessere Lösungen sind willkommen!

Answer 1

Versuchen:

vector.flatMapValues(_.toSeq)