為什么我們使用Val而不是Var作為累加器?如果它就像一個為多個執行程式節點共享的計數器以更新/更改它,那么這意味著重新分配一個 Val 對嗎?
val accum = sc.longAccumulator("New Accumulator")
uj5u.com熱心網友回復:
在這種情況下,我們正在實體化一個 LongAccumulator 類。您的邏輯沒有錯,但是我們存盤的物件accum是靜態的,但是在這個物件內部,我們有兩個var值。sum并且count物件是不可變的。但它里面的值不是。
您可以在此處查看代碼的詳細資訊。
轉載請註明出處,本文鏈接:https://www.uj5u.com/yidong/522038.html
標籤:阿帕奇火花斯卡拉火花
下一篇:有條件地展開SparkSQL
