/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

8 votes117 views3 answers
Data type
Python
14 votes118 views6 answers
Install django
Python
0 vote123 views2 answers
Call javascript function flask
Python
0 vote127 views1 answer
Df.loc jupyter
Python
2 votes119 views3 answers
How to increase bar width in python matplogtlib
Python
-1 vote117 views1 answer
Gdscript iterate over dictionary
Python
2 votes112 views3 answers
Coronavirus tips
Python
0 vote119 views1 answer
Read specific rows from csv in python
Python
-1 vote127 views3 answers
Play Video in Google Colab
Python
1 vote124 views1 answer
Complex phase python
Python