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

2016-07-21 20 views 0 likes

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!

2016-07-21 kambiz

Antwort

Versuchen:

vector.flatMapValues(_.toSeq)

2016-07-21 14:59:00

Fehler: Wert flatMapValues ist kein Mitglied von scala.collection.mutable.HashMap [String, Double] – kambiz

Vektor nur der Name des RDD ist, die alles sein könnte. – kambiz

Ich habe dies stattdessen versucht: vector.flatMapValues (x => x). Es hat perfekt funktioniert. Danke für den Tipp! – kambiz