2016-07-21 5 views
0

に私が得た:Apacheのスパーク - スカラ - HashMapの(K、HashMapの[文字列、ダブル](V1、V2、...))((K、V1)、(K、V2)、...)

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)), ...] 

を行うことができます方法:

は私が取得したいですか?より良いソリューションは大歓迎です!

答えて

1

試してみてください。

vector.flatMapValues(_.toSeq) 
+0

エラー:値flatMapValues – kambiz

+0

ベクトルは何もすることができRDDの名前だけで[文字列、ダブル] scala.collection.mutable.HashMapのメンバーではありません。 – kambiz

+0

代わりにこれを試しました:vector.flatMapValues(x => x)。それは完璧に働いた。ヒントありがとう! – kambiz

関連する問題