我在RDD中有这样的数据:
RDD[((Int, Int, Int), ((Int, Int), Int))]
如:
(((9,679,16),((2,274),1)), ((250,976,13),((2,218),1)))
我希望输出为:
((9,679,16,2,274,1),(250,976,13,2,218,1))
加入2 rdds后:
val joinSale = salesTwo.join(saleFinal)
我得到了结果集.我尝试了以下代码.
joinSale.flatMap(x => x).take(100).foreach(println)
我试过map/flatMap但是做不到.任何想法如何实现这样的场景？提前致谢 ..