flatMap
次のようにrddでリストを平坦化するために使用する方法はありますか:
rdd = sc.parallelize([[1,2,3],[6,7,8]])
rdd.flatMap(lambda r: [[r[0],r[1],r[2],[r[2]+1,r[2]+2]]]).collect()
私の望む出力:
[[1,2,3,4,5],[6,7,8,9,10]]
実際の出力:
[[1,2,3,[4,5]], [6,7,8,[9,10]]]
配列を適切に平坦化することは理解flatMap
しており、上記の実際の出力について混乱していませんが、内部リストを効果的に平坦化する方法があるかどうか知りたいです。