/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 vote309 views1 answer
Compute Count2(AACAAGCTGATAAACATTTAAAGAG, AAAAA). in python
Python
1 vote305 views1 answer
Import mean squared log error
Python
0 vote290 views1 answer
Non blocking socket python
Python
0 vote304 views1 answer
Extends template django file system
Python
0 vote407 views1 answer
Using a generic exception block
Python
39 votes312 views5 answers
Round off to two decimal places python
Python
3 votes304 views2 answers
Python get utc time
Python
0 vote326 views1 answer
Pandas scientific notation
Python
8 votes312 views2 answers
Python using webbrowser
Python
0 vote297 views1 answer
How to open a widget using sputil.get
Python