/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

85 votes155 views6 answers
For python
Python
2 votes134 views1 answer
Add trendline to plot matplotlib
Python
-1 vote182 views1 answer
Django email verification
Python Django
6 votes165 views1 answer
Enter key press bind tkinter
Python
0 vote162 views1 answer
Dividing counter object in python
Python
1 vote135 views2 answers
How can you know if a year is a leap year
Python
3 votes153 views2 answers
Add in python
Python
0 vote153 views1 answer
Python change type of every element in a dictionary
Python
0 vote173 views1 answer
Qlistwidget item clicked event pyqt
Python
1 vote149 views2 answers
Get required packages from python project
Python