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)), ...]
を行うことができます方法:
は私が取得したいですか?より良いソリューションは大歓迎です!
エラー:値flatMapValues – kambiz
ベクトルは何もすることができRDDの名前だけで[文字列、ダブル] scala.collection.mutable.HashMapのメンバーではありません。 – kambiz
代わりにこれを試しました:vector.flatMapValues(x => x)。それは完璧に働いた。ヒントありがとう! – kambiz