/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

16 votes273 views2 answers
Python how to remove n from string
Python
2 votes288 views1 answer
Python project tutorial
Python
0 vote327 views1 answer
Python to C++ converter
Python
3 votes319 views4 answers
Python list group by count
Python
9 votes314 views1 answer
Python remove duplicates from a list
Python
53 votes296 views3 answers
How to find length of list python
Python
1 vote323 views1 answer
Selenium find cell based on coordinates
Python
9 votes312 views6 answers
Elif python
Python
2 votes271 views1 answer
Make tkinter window look less blury
Python
1 vote305 views1 answer
Write a python program to find gcd of two numbers
Python