/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

10 votes103 views4 answers
Python bold text
Python
0 vote108 views1 answer
Python class destroying
Python
0 vote121 views6 answers
Django wht post save signal not firing
Python
0 vote93 views1 answer
Django rest framework multiple user registration
Python Django
0 vote128 views1 answer
Rotate image pyqt5
Python
0 vote102 views1 answer
Extra import on django
Python
0 vote112 views1 answer
Convert tuple to array python
Python
0 vote106 views1 answer
How to make a grid list in python
Python
0 vote139 views1 answer
Dimension of an indez pandas
Python
42 votes110 views6 answers
Train test split pandas
Python