/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

0 vote230 views2 answers
Convert python code to C code
Python
1 vote197 views1 answer
Python pandas save df to xlsx file
Python
1 vote242 views1 answer
Django how to set a navbar active
Python
0 vote186 views1 answer
Csv.DictReader Skip Lines
Python
0 vote196 views1 answer
Make widget span window width tkinter
Python
22 votes195 views2 answers
Export pandas dataframe as excel
Python
-1 vote230 views2 answers
Python dict remove duplicates where items are not the same
Python
2 votes208 views2 answers
How to read then overwrite a file with python
Python
185 votes216 views6 answers
How to update pip in python
Python
15 votes196 views4 answers
Cv2 show image
Python