RDD에서 배열을 병합하는 방법

Question

나는 Spark의 초보자입니다. 나는 [[(문자열, 문자열, 문자열)] 배열] 다음 RDD이

내가 r1.reduce(_ ++ _)하여이 작업을 수행 할 수

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

처럼의 배열을 병합 할

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)