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
相关文章
相关标签/搜索