아파치 스파크 - 스칼라 -의 HashMap (K, HashMap의 [문자열, 더블 (V1, V2, ..))에 ((K, V1), (K, V2), ...)

Question

내가 가지고 :

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

이 FlatMap와

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

을 수행 할 수 있습니다 방법 :

나는 싶어? 더 나은 솔루션을 환영합니다!

Answer 1

시도 :

vector.flatMapValues(_.toSeq)