/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

1 vote93 views1 answer
Geodataframe change crs
Python
0 vote111 views1 answer
How to change the height of an input in python tkinter
Python
0 vote52 views1 answer
Freqtrade - Informative Pairs
Python
12 votes130 views6 answers
Python progress bar
Python
0 vote114 views1 answer
Is python idle an ide
Python
0 vote97 views1 answer
Split python strings into pairs & complete uneven pairs
Python
0 vote97 views1 answer
Python: dunder init method
Python
0 vote102 views1 answer
How to redirect where requests library downloads file python
Python
4 votes125 views2 answers
Django template for range
Python Django
10 votes97 views4 answers
How to check if Python is 32 or 64 bit
Python