/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 votes216 views2 answers
Python replace only first instance
Python
0 vote191 views1 answer
Converting utc time string to datetime object python
Python
0 vote177 views1 answer
Python inherit from objects
Python
1 vote172 views3 answers
Isprime in python
Python
0 vote220 views1 answer
PY | websocket - server
Python
1 vote180 views1 answer
How to parse dicts in reqparse in flask
Python
39 votes200 views4 answers
Typing racer
Python
0 vote199 views1 answer
Round up
Python
0 vote199 views1 answer
Pandas read_csv drop column
Python
0 vote222 views1 answer
ModuleNotFoundError: No module named 'wtforms.fields.html5'
Python