Package pyspark :: Module accumulators :: Class AddingAccumulatorParam

Class AddingAccumulatorParam

      object --+    
               |    
AccumulatorParam --+
                   |
                  AddingAccumulatorParam

An AccumulatorParam that uses the + operators to add values. Designed for simple types such as integers, floats, and lists. Requires the zero value for the underlying type as a parameter.

Instance Methods

__init__(self, zero_value)
x.__init__(...) initializes x; see help(type(x)) for signature

source code

zero(self, value)
Provide a "zero value" for the type, compatible in dimensions with the provided value (e.g., a zero vector) source code

addInPlace(self, value1, value2)
Add two values of the accumulator's data type, returning a new value; for efficiency, can also update value1 in place and return it. source code

Inherited from object: __delattr__, __format__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __repr__, __setattr__, __sizeof__, __str__, __subclasshook__