/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

0 vote347 views1 answer
Hazm
Python
1 vote358 views1 answer
How to redefine a legend in pandas
Python
0 vote344 views4 answers
Ip address regex
Python
0 vote338 views1 answer
How to fix valueerror in python
Python
0 vote336 views1 answer
Python output parameter
Python
0 vote370 views1 answer
How to add another timestamp column plus two hours
Python
0 vote398 views1 answer
Def f(x) python
Python
6 votes338 views2 answers
Python reverse words and swap case
Python
6 votes366 views1 answer
Python lambda key sort
Python
24 votes318 views3 answers
For loop shorthand python
Python