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
Post a Comment