/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

10 votes273 views4 answers
Discord.py events
Python
0 vote268 views1 answer
Get category discord.py
Python
0 vote301 views2 answers
Call for a last number in series python
Python
59 votes276 views6 answers
Classes in python
Python
5 votes296 views3 answers
Python change column order in dataframe
Python
16 votes262 views4 answers
Tqdm library
Python
1 vote263 views1 answer
Python twilio certificate error
Python
15 votes279 views2 answers
Python check if variable is string
Python
0 vote285 views1 answer
Importare un foglio di un file excel in python
Python
0 vote270 views1 answer
Tkinter while button not pressed
Python