/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 vote434 views1 answer
How to set up flash message in html template in flask app
Python Flask
13 votes368 views2 answers
Delete database entry using name django
Python
28 votes334 views6 answers
Import JSON in python
Python
7 votes358 views5 answers
Convert categorical variable to numeric python
Python
2 votes328 views1 answer
How to check weather my model is on gpu in pytorch
Python
1 vote349 views1 answer
Python define an array of dictonary
Python
0 vote423 views1 answer
Django fixtures. To dump data
Python Django
1 vote354 views1 answer
Python reload lib jupyter notebook %reload
Python
9 votes365 views4 answers
Change column order pandas
Python
1 vote341 views1 answer
Animations text terminal python
Python