pyspark.AccumulatorParamgydF4y2Ba¶gydF4y2Ba
-
類gydF4y2Ba
pyspark。gydF4y2BaAccumulatorParamgydF4y2Ba¶gydF4y2Ba -
Helper對象定義了如何給定類型的累積值。gydF4y2Ba
例子gydF4y2Ba
> > >gydF4y2Ba從gydF4y2Bapyspark.accumulatorsgydF4y2Ba進口gydF4y2BaAccumulatorParamgydF4y2Ba> > >gydF4y2Ba類gydF4y2BaVectorAccumulatorParamgydF4y2Ba(gydF4y2BaAccumulatorParamgydF4y2Ba):gydF4y2Ba…gydF4y2BadefgydF4y2Ba零gydF4y2Ba(gydF4y2Ba自我gydF4y2Ba,gydF4y2Ba價值gydF4y2Ba):gydF4y2Ba…gydF4y2Ba返回gydF4y2Ba(gydF4y2Ba0.0gydF4y2Ba]gydF4y2Ba*gydF4y2BalengydF4y2Ba(gydF4y2Ba價值gydF4y2Ba)gydF4y2Ba…gydF4y2BadefgydF4y2BaaddInPlacegydF4y2Ba(gydF4y2Ba自我gydF4y2Ba,gydF4y2Baval1gydF4y2Ba,gydF4y2Baval2gydF4y2Ba):gydF4y2Ba…gydF4y2Ba為gydF4y2Ba我gydF4y2Ba在gydF4y2Ba範圍gydF4y2Ba(gydF4y2BalengydF4y2Ba(gydF4y2Baval1gydF4y2Ba)):gydF4y2Ba…gydF4y2Baval1gydF4y2Ba(gydF4y2Ba我gydF4y2Ba]gydF4y2Ba+ =gydF4y2Baval2gydF4y2Ba(gydF4y2Ba我gydF4y2Ba]gydF4y2Ba…gydF4y2Ba返回gydF4y2Baval1gydF4y2Ba> > >gydF4y2Ba弗吉尼亞州gydF4y2Ba=gydF4y2BascgydF4y2Ba。gydF4y2Ba蓄電池gydF4y2Ba([gydF4y2Ba1.0gydF4y2Ba,gydF4y2Ba2.0gydF4y2Ba,gydF4y2Ba3.0gydF4y2Ba),gydF4y2BaVectorAccumulatorParamgydF4y2Ba())gydF4y2Ba> > >gydF4y2Ba弗吉尼亞州gydF4y2Ba。gydF4y2Ba價值gydF4y2Ba(1.0,2.0,3.0)gydF4y2Ba> > >gydF4y2BadefgydF4y2BaggydF4y2Ba(gydF4y2BaxgydF4y2Ba):gydF4y2Ba…gydF4y2Ba全球gydF4y2Ba弗吉尼亞州gydF4y2Ba…gydF4y2Ba弗吉尼亞州gydF4y2Ba+ =gydF4y2Ba(gydF4y2BaxgydF4y2Ba]gydF4y2Ba*gydF4y2Ba3gydF4y2Ba> > >gydF4y2Ba抽樣gydF4y2Ba=gydF4y2BascgydF4y2Ba。gydF4y2Ba並行化gydF4y2Ba([gydF4y2Ba1gydF4y2Ba,gydF4y2Ba2gydF4y2Ba,gydF4y2Ba3gydF4y2Ba])gydF4y2Ba> > >gydF4y2Ba抽樣gydF4y2Ba。gydF4y2BaforeachgydF4y2Ba(gydF4y2BaggydF4y2Ba)gydF4y2Ba> > >gydF4y2Ba弗吉尼亞州gydF4y2Ba。gydF4y2Ba價值gydF4y2Ba(7.0,8.0,9.0)gydF4y2Ba
方法gydF4y2Ba
addInPlacegydF4y2Ba(value1, value2)gydF4y2Ba添加兩個值累加器的數據類型,返回一個新的價值;為了提高效率,也可以更新gydF4y2Bavalue1gydF4y2Ba並返回它。gydF4y2Ba
零gydF4y2Ba(值)gydF4y2Ba提供“零值”類型,兼容與所提供的尺寸gydF4y2Ba價值gydF4y2Ba(比如,一個零向量)gydF4y2Ba