/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

6 votes224 views1 answer
What is ipython
Python
1 vote281 views1 answer
Add search field to django admin
Python Django
0 vote219 views2 answers
Javascript parse url
Python
10 votes247 views1 answer
Create dataframe with column names pandas
Python
1 vote225 views2 answers
How to 404 custom page not found in django
Python Django
4 votes249 views2 answers
Change django admin title
Python
0 vote277 views1 answer
Candle stick with volume plotly
Python
0 vote236 views1 answer
Create a DataFrame containing elements in a range
Python
4 votes196 views8 answers
Discord.py embed
Python
5 votes227 views1 answer
Generate a color python
Python