/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

32 votes289 views6 answers
Array in python
Python
0 vote280 views1 answer
Python dataframe appendisnt showing
Python
0 vote344 views1 answer
How to submit two forms in django
Python Django
-1 vote309 views1 answer
Python webscraper stack overflow
Python
0 vote303 views1 answer
Casting float value to an integer in Python
Python
1 vote323 views2 answers
Querydict instance is immutable
Python
2 votes289 views1 answer
Set django static root
Python
0 vote303 views1 answer
Pyqt5 udp example
Python
0 vote311 views1 answer
Connect to vvenv python
Python
0 vote326 views1 answer
Django update replace regex
Python Django