/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 vote234 views1 answer
Add legend to colorbar
Python
0 vote201 views1 answer
How to duplicate a row in python
Python
2 votes205 views2 answers
Pass variable to thread target
Python
145 votes211 views5 answers
How to generate a random number python
Python
0 vote215 views1 answer
How to remove last 2 rows in a dataframe
Python
1 vote199 views1 answer
Url in form action django
Python
4 votes235 views2 answers
Count characters in string python
Python
0 vote216 views1 answer
Sorts this RDD by the given keyfunc
Python
2 votes199 views1 answer
Module 'pygame' has no 'init' member
Python
156 votes242 views10 answers
Python random
Python