RDDで配列をマージする方法

Question

私はSparkの初心者です。私はr1.reduce(_ ++ _)でこれを行うことができます

Array((123,456,789), (AAA,BBB,CCC), (DDD,EEE,FFF), (E1,E2,E3)) 

みたいに配列をマージしたい次RDD [アレイ[（文字列、文字列、文字列）]]

val r1 = sc.parallelize(Array(Array(("123","456","789"),("AAA","BBB","CCC")),Array(("DDD","EEE","FFF"),("E1","E2","E3")))) 

を持っています。しかし、私はマップのような変換機能を使用して、アクションは使用しません。それは可能ですか？私はSpark 1.3.1を使用しています。

は、あなたが行うことができます

Answer 1

ありがとう：

val res: RDD[(String, String, String)] = r1.flatMap(identity)