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


i got:

val vector: rdd[(string, hashmap[string,double])] = [("a", {("x",1.0),("y", 2.0),...}] 

i want get:

rdd[string,(string,double)] = [("a",("x",1.0)), ("a", ("y", 2.0)), ...] 

how can done flatmap? better solutions welcome!

try:

vector.flatmapvalues(_.toseq) 

Comments