Apache Spark 从 ArrayList 添加数字

Question

我正在寻找一个添加现有 Integer ArrayList 元素的 Spark 程序。我在 apache spark 中进行了所有转换和操作，但找不到合适的程序来添加元素。

如果有人能告诉我如何编写上述代码，即在 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

希望对你有帮助。