为什么我们在累加器中使用Val而在标量中不使用Var

Question

为什么我们使用Val而不是Var用于累加器？如果它就像一个计数器，由多个执行器节点共享以更新/更改它，那么这意味着重新分配Val，对吗？

val accum = sc.longAccumulator("New Accumulator")

Answer 1

在本例中，我们正在实例化一个LongAccumulator类。您的逻辑没有错，但我们存储在accum中的对象是静态的，但在这个对象内部，我们有两个var值。CCD_ 4和CCD_。但它内部的价值观并非如此。

您可以在此处查看代码的详细信息。