キー値タプルの値タプルを平坦化する方法は？

Question

私は[(Int, Iterable[Int])]（キー値形式）のようなRDDを持っています。私は価値の部分を平らにしたい。あなたが探している場合

rdd.flatMap(x => x._2.map(y => y)).foreach(println) 

を行うことによって解決すべき値の一部を平坦化

error: value _2 is not a member of Any rdd.productIterator.foreach(x => x._2.productIterator.foreach(print))

Answer 1

：

私が試してみました：

rdd.productIterator.foreach(x => x._2.productIterator.foreach(print)) 

をしかし、私は次のエラーを取得します〜flatten反復可能な値はそして、それはあなたがしたいように見える

rdd.flatMap(x => x._2.map(y => (x._1, y))).foreach(println) 

Answer 2

あなたの問題を解決する必要があり、次のflatMapValues：

val rdd: RDD[(Int, Iterable[Int])] = sc.parallelize(Seq((1, Seq(1, 2, 3)))) 
rdd.flatMapValues(idenitity)