Apache Spark從ArrayList中添加數字

Question

我正在尋找一個Spark程序，它添加了一個現有的Integer ArrayList.I的元素，經歷了apache中的所有轉換和操作，但找不到合適的人來添加元素。

如果有人可以告訴我如何編寫上面的代碼，即在spark中添加一個arraylist的元素，那麼它會很棒。

謝謝。

Answer 1

如果你有一個RDD [INT]如下圖所示：

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

你可以做以下補充名單的元素：

myRdd.reduce(_+_) 

res1: Int = 21 

或者你可以做以下的以及：

myRdd.fold(0)(_+_) 

res6: Int = 21 

希望它有幫助。