/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 vote165 views1 answer
Punto1
Python
0 vote245 views1 answer
Getting multiple of 5 python
Python
0 vote169 views1 answer
Two input string sum in django
Python
3 votes166 views1 answer
N random numbers python
Python
13 votes156 views6 answers
Import matplotlib.pyplot as plt
Python
6 votes179 views2 answers
Python min in dictionary
Python
0 vote173 views2 answers
Pandas remove repeated index
Python
2 votes171 views1 answer
Spyder - comment banch of codee
Python
0 vote189 views1 answer
The Python 2 bindings for rpm are needed for this module. If you require Python 3 support use the `dnf` Ansible module instead.. The Python 2 yum module is needed for this module. If you require Python 3 support use the `dnf` Ansible module instead.
Python
5 votes196 views2 answers
Python all lowercase letters
Python