/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

2 votes126 views2 answers
Python add list to dictionary in loop
Python
0 vote140 views2 answers
How to round to 3 significant figures in python
Python
-1 vote136 views2 answers
Sequence in python
Python
0 vote142 views2 answers
Numpy random in python
Python
0 vote137 views1 answer
Tkinter navigate pages
Python
4 votes132 views2 answers
Primary key django model
Python
13 votes137 views3 answers
Np.hstack in python
Python
-1 vote130 views1 answer
Unocode error pytonn
Python
14 votes134 views6 answers
If condition python
Python
0 vote131 views1 answer
Pandas drop rows with empty list
Python