Я заархивировал три RDD и в результате получил вложенную структуру.
val rdd1 = sc.parallelize(List(1, 2, 3))
val rdd2 = sc.parallelize(List(3, 4, 5))
val rdd3 = sc.parallelize(List(6, 7, 8))
val finalRDD = rdd1.zip(rdd2).zip(rdd3)
finalRDD
выглядит как
((1,3),6)
((2,4),7)
((3,5),8)
Как мне сгладить структуру следующим образом?
(1,3,6)
(2,4,7)
(3,5,8)