pyspark.SparkContext.accumulator

SparkContext。 蓄电池 ( 价值:T,accum_param:可选(AccumulatorParam(T]]=没有一个 )→蓄电池(T]

创建一个蓄电池用给定的初始值,使用一个给定的AccumulatorParamhelper对象定义如何添加值的数据类型。默认AccumulatorParams用于整数和浮点数如果你不提供。对于其他类型,可以使用一个定制的AccumulatorParam。