/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

3 votes146 views2 answers
Pandas - from umeric to string
Python
0 vote143 views1 answer
%%writefile jupyter
Python
0 vote215 views1 answer
Conditional Statements to Skip Items
Python
29 votes155 views5 answers
Static dirs django
Python
-1 vote147 views2 answers
Matplotlib set colorbar range
Python
3 votes145 views1 answer
Python strlen
Python
1 vote164 views1 answer
How to give multiple option to the user and ask the same question again and again until the user tells one of the options
Python
0 vote176 views1 answer
Create a colun in pandas using groupby
Python
0 vote188 views1 answer
Cannot cast type smallint to boolean django
Python Django
-1 vote169 views1 answer
Django cheat sheet pdf
Python