/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

46 votes309 views6 answers
Dataframe to CSV
Python
0 vote322 views1 answer
Nlp spacy medium
Python
0 vote315 views1 answer
Set change order python
Python
0 vote334 views2 answers
Pyton como identificar se é numero
Python
0 vote330 views1 answer
How to make a clicker game in python
Python
1 vote282 views1 answer
Plotly font size
Python
0 vote382 views1 answer
Include app in django project
Python Django
0 vote329 views1 answer
Reverse row order padnas
Python
1 vote334 views1 answer
Log loss python
Python
0 vote341 views1 answer
Open image from link python
Python