sparkCore之共享變量

概述: 所謂共享變量,是爲了解決task中使用到外部變量形成相關問題而出現的。spark提供了有限的兩種共享變量:廣播變量Broadcast變量和累加器Accumulator。java 1、 Broadcast 一、使用說明 使用很是簡單,只須要將普通的變量包裝爲Broadcast便可: ​ val xxBC:Broadcast[T] = sc.broadcast(t); 其中T是被包裝的變量t的
相關文章
相關標籤/搜索