/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

2 votes135 views2 answers
Django exclude queryset
Python Django
7 votes97 views3 answers
Np array to df
Python
0 vote98 views1 answer
Pretty print list python
Python
0 vote97 views1 answer
Check is string is nan python
Python
0 vote102 views1 answer
Pip install for python 2 and python3
Python
79 votes99 views6 answers
Python current working directory
Python
1 vote149 views1 answer
Indentation levels in programming
Python
0 vote99 views1 answer
Python currnent time
Python
0 vote142 views1 answer
Django default template location
Python Django
3 votes111 views1 answer
Clean punctuation from string python
Python