/Python/Reduces the elements of this RDD using the specified commutative and associative binary operator

Reduces the elements of this RDD using the specified commutative and associative binary operator

from operator import add
sc.parallelize([1, 2, 3, 4, 5]).reduce(add)
# 15
sc.parallelize((2 for _ in range(10))).map(lambda x: 1).cache().reduce(add)
# 10
sc.parallelize([]).reduce(add)
"""
Traceback (most recent call last):
    ...
ValueError: Can not reduce() empty RDD
"""

Source: spark.apache.org

Similar codes

1 vote135 views1 answer
How to find permutation of three numbers in python list
Python
0 vote152 views3 answers
Numpy.dot
Python
0 vote141 views2 answers
Python dict for k v
Python
1 vote117 views3 answers
Python filter dictionary
Python
0 vote135 views1 answer
A GDAL API version must be specified. Provide a path to gdal-config using a GDAL_CONFIG environment variable or use a GDAL_VERSION environment variable.
Python
0 vote119 views1 answer
Keras name model
Python
37 votes130 views6 answers
Json dumps python
Python
1 vote129 views3 answers
Accessing data on django sessionstore
Python
0 vote114 views1 answer
Directory corrente python
Python
0 vote118 views1 answer
Pandas df filter by time hour
Python