/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

3 votes254 views1 answer
Join two numpy 2d array
Python
0 vote232 views1 answer
Feature importance naive bayes python
Python
0 vote260 views3 answers
ModuleNotFoundError: No module named 'numpy.testing.decorators'
Python
4 votes253 views2 answers
Django template for range
Python Django
18 votes259 views3 answers
How to clear command prompt python
Python
3 votes232 views3 answers
Gcd function in python
Python
0 vote252 views2 answers
Matplotlib-Object oriented interface
Python
1 vote226 views1 answer
How to change size of xticks
Python
0 vote243 views1 answer
Tweepy aut code
Python
0 vote271 views2 answers
Django template date format yyyy-mm-dd
Python Django