/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

40 votes164 views6 answers
Pandas replace null with 0
Python
1 vote153 views1 answer
'set' object is not reversible
Python
8 votes159 views6 answers
Calculator in python
Python
0 vote156 views1 answer
How to add list as a column to dataframe
Python
1 vote169 views1 answer
Error: Command '['/home/robert/python/python_p/env/bin/python3.8', '-Im', 'ensurepip', '--upgrade', '--default-pip']' returned non-zero exit status 1.
Python
0 vote162 views1 answer
Virtual mic with python
Python
0 vote186 views1 answer
Creating base models django
Python Django
1 vote165 views1 answer
Order by listview django
Python
9 votes145 views2 answers
Euclidean distance
Python
2 votes166 views2 answers
Convert list to generator python
Python