/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

4 votes254 views3 answers
Astype float across columns pandas
Python
0 vote208 views1 answer
Hackerrank solutions python 3
Python
0 vote278 views1 answer
Django validate_comma_separated_integer_list
Python Django
0 vote258 views1 answer
How to use put method in django
Python Django
0 vote272 views2 answers
Pairwise swap in data structure in python
Python
1 vote251 views1 answer
Add padding to 2d matrix \np
Python
0 vote246 views2 answers
Allow x_frame_options django
Python
3 votes243 views3 answers
Extract domain name from url python
Python
0 vote228 views1 answer
Captions overlap in seaborn plot jupyter
Python
-1 vote233 views1 answer
Python library to convert decimal into octal and hexadecimal
Python