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
而gydF4y2Ba
SparkContextgydF4y2Ba
支持等原始數據類型的蓄電池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