通常在应用Spark算子函数，比如应用map()或reduce函数我们向函数传入条件时，函数内部可以应用驱动程序中定义的变量，但是这样会使集群中所有义务都会得到变量新的副本，这些副本的更新不会流传回驱动程序，致使读写同享变量效力低下或内存溢出，为懂得决这个问题Spark供给了两种同享变量类型：广播变量和累加器通常在应用Spark算子函数，比如应用map()或reduce函数我们向函数传入条件时，函数内部可以
阅读背景：
Spark学习实例(Python)：共享变量SharedVariables
来源：互联网
分享到：
