sparkCore之共享变量

概述: 所谓共享变量,是为了解决task中使用到外部变量形成相关问题而出现的。spark提供了有限的两种共享变量:广播变量Broadcast变量和累加器Accumulator。java 1、 Broadcast 一、使用说明 使用很是简单,只须要将普通的变量包装为Broadcast便可: ​ val xxBC:Broadcast[T] = sc.broadcast(t); 其中T是被包装的变量t的
相关文章
相关标签/搜索