아파치 스파크가 ArrayList에서 숫자를 더하기 위해

Question

나는 기존의 Integer ArrayList의 요소를 추가하는 Spark 프로그램을 찾고있었습니다. 아파치 스파크의 모든 변환과 액션을 거쳤지만 추가 할 수있는 스파크 프로그램을 찾지 못했습니다. 집단.

누군가가 위의 코드를 작성하는 방법을 말해 줄 수 있다면, 즉 스파크에 arraylist의 요소를 추가하면 큰 도움이 될 것입니다.

감사합니다.

Answer 1

는 아래 그림과 같이 당신은 RDD [지능]이있는 경우 : 당신이 목록의 요소를 추가하려면 다음을 수행 할 수

val myRdd = sc.parallelize(Seq(1,2,3,4,5,6)) 

는 :

myRdd.reduce(_+_) 

res1: Int = 21 

아니면로 다음을 수행 할 수 음 :

myRdd.fold(0)(_+_) 

res6: Int = 21 

희망이 있습니다.