pyspark.AccumulatorgydF4y2Ba¶gydF4y2Ba

類gydF4y2Ba pyspark。gydF4y2Ba 蓄電池gydF4y2Ba (gydF4y2Ba 援助gydF4y2Ba:gydF4y2BaintgydF4y2Ba,gydF4y2Ba價值gydF4y2Ba:gydF4y2BaTgydF4y2Ba,gydF4y2Baaccum_paramgydF4y2Ba:gydF4y2Bapyspark.accumulators.AccumulatorParamgydF4y2Ba(gydF4y2BaTgydF4y2Ba]gydF4y2Ba )gydF4y2Ba ¶gydF4y2Ba

一個共享變量,可以積累。,h一個s a commutative and associative “add” operation. Worker tasks on a Spark cluster can add values to an Accumulator with the+ =gydF4y2Ba運營商,但隻允許訪問其價值驅動程序,使用gydF4y2Ba價值gydF4y2Ba。更新從工人自動傳播到驅動程序。gydF4y2Ba

而gydF4y2BaSparkContextgydF4y2Ba支持等原始數據類型的蓄電池gydF4y2BaintgydF4y2Ba和gydF4y2Ba浮動gydF4y2Ba,用戶也可以通過提供一個自定義定義定製類型的蓄電池gydF4y2BaAccumulatorParamgydF4y2Ba對象。指doctest的一個例子。gydF4y2Ba

例子gydF4y2Ba

           > > >gydF4y2Ba一個gydF4y2Ba=gydF4y2BascgydF4y2Ba。gydF4y2Ba蓄電池gydF4y2Ba(gydF4y2Ba1gydF4y2Ba)gydF4y2Ba> > >gydF4y2Ba一個gydF4y2Ba。gydF4y2Ba價值gydF4y2Ba1gydF4y2Ba> > >gydF4y2Ba一個gydF4y2Ba。gydF4y2Ba價值gydF4y2Ba=gydF4y2Ba2gydF4y2Ba> > >gydF4y2Ba一個gydF4y2Ba。gydF4y2Ba價值gydF4y2Ba2gydF4y2Ba> > >gydF4y2Ba一個gydF4y2Ba+ =gydF4y2Ba5gydF4y2Ba> > >gydF4y2Ba一個gydF4y2Ba。gydF4y2Ba價值gydF4y2Ba7gydF4y2Ba> > >gydF4y2BascgydF4y2Ba。gydF4y2Ba蓄電池gydF4y2Ba(gydF4y2Ba1.0gydF4y2Ba)gydF4y2Ba。gydF4y2Ba價值gydF4y2Ba1.0gydF4y2Ba> > >gydF4y2BascgydF4y2Ba。gydF4y2Ba蓄電池gydF4y2Ba(gydF4y2Ba1gydF4y2BajgydF4y2Ba)gydF4y2Ba。gydF4y2Ba價值gydF4y2Ba1 jgydF4y2Ba> > >gydF4y2Ba抽樣gydF4y2Ba=gydF4y2BascgydF4y2Ba。gydF4y2Ba並行化gydF4y2Ba([gydF4y2Ba1gydF4y2Ba,gydF4y2Ba2gydF4y2Ba,gydF4y2Ba3gydF4y2Ba])gydF4y2Ba> > >gydF4y2BadefgydF4y2BafgydF4y2Ba(gydF4y2BaxgydF4y2Ba):gydF4y2Ba…gydF4y2Ba全球gydF4y2Ba一個gydF4y2Ba…gydF4y2Ba一個gydF4y2Ba+ =gydF4y2BaxgydF4y2Ba> > >gydF4y2Ba抽樣gydF4y2Ba。gydF4y2BaforeachgydF4y2Ba(gydF4y2BafgydF4y2Ba)gydF4y2Ba> > >gydF4y2Ba一個gydF4y2Ba。gydF4y2Ba價值gydF4y2Ba13gydF4y2Ba> > >gydF4y2BabgydF4y2Ba=gydF4y2BascgydF4y2Ba。gydF4y2Ba蓄電池gydF4y2Ba(gydF4y2Ba0gydF4y2Ba)gydF4y2Ba> > >gydF4y2BadefgydF4y2BaggydF4y2Ba(gydF4y2BaxgydF4y2Ba):gydF4y2Ba…gydF4y2BabgydF4y2Ba。gydF4y2Ba添加gydF4y2Ba(gydF4y2BaxgydF4y2Ba)gydF4y2Ba> > >gydF4y2Ba抽樣gydF4y2Ba。gydF4y2BaforeachgydF4y2Ba(gydF4y2BaggydF4y2Ba)gydF4y2Ba> > >gydF4y2BabgydF4y2Ba。gydF4y2Ba價值gydF4y2Ba6gydF4y2Ba
          

           > > >gydF4y2Ba抽樣gydF4y2Ba。gydF4y2Ba地圖gydF4y2Ba(gydF4y2BaλgydF4y2BaxgydF4y2Ba:gydF4y2Ba一個gydF4y2Ba。gydF4y2Ba價值gydF4y2Ba)gydF4y2Ba。gydF4y2Ba收集gydF4y2Ba()gydF4y2Ba回溯(最近的電話):gydF4y2Ba…gydF4y2BaPy4JJavaErrorgydF4y2Ba:gydF4y2Ba…gydF4y2Ba
          

           > > >gydF4y2BadefgydF4y2BahgydF4y2Ba(gydF4y2BaxgydF4y2Ba):gydF4y2Ba…gydF4y2Ba全球gydF4y2Ba一個gydF4y2Ba…gydF4y2Ba一個gydF4y2Ba。gydF4y2Ba價值gydF4y2Ba=gydF4y2Ba7gydF4y2Ba> > >gydF4y2Ba抽樣gydF4y2Ba。gydF4y2BaforeachgydF4y2Ba(gydF4y2BahgydF4y2Ba)gydF4y2Ba回溯(最近的電話):gydF4y2Ba…gydF4y2BaPy4JJavaErrorgydF4y2Ba:gydF4y2Ba…gydF4y2Ba
          

           > > >gydF4y2BascgydF4y2Ba。gydF4y2Ba蓄電池gydF4y2Ba([gydF4y2Ba1.0gydF4y2Ba,gydF4y2Ba2.0gydF4y2Ba,gydF4y2Ba3.0gydF4y2Ba])gydF4y2Ba回溯(最近的電話):gydF4y2Ba…gydF4y2BaTypeErrorgydF4y2Ba:gydF4y2Ba…gydF4y2Ba
          

方法gydF4y2Ba

添加gydF4y2Ba(術語)gydF4y2Ba

添加一個術語蓄電池的價值gydF4y2Ba

屬性gydF4y2Ba

價值gydF4y2Ba

蓄電池的價值;隻在驅動程序可用gydF4y2Ba

以前的gydF4y2Ba

pyspark.BroadcastgydF4y2Ba

下一個gydF4y2Ba

pyspark.AccumulatorParamgydF4y2Ba