map 操做 rdd內元素,寫出、更新內容,不報錯,可是沒法寫出

錯誤分析變量 1,rdd內不能再進行rdd操做map 2,若是有外部變量解決方案 如co var a………………錯誤 rdd1.map({ 處理代碼 更新 a }) 則不會報錯但a不會更新   解決方案 1,累加器 var accum_ind = sc.accumulator(1, "clk") iii = accum_ind.value accum_ind+=1 能夠實現一些記錄操做 2  co
相關文章
相關標籤/搜索