/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 vote248 views1 answer
Pandas head sort by colun name
Python
8 votes277 views1 answer
Python keylogger
Python
0 vote262 views1 answer
Requirements.txt dev python
Python
0 vote243 views1 answer
How to resume request downloads
Python
0 vote251 views1 answer
Outlier removal
Python
0 vote245 views1 answer
Get a list of ids from queryset django
Python
0 vote275 views1 answer
How to discover which index labels are in other
Python
0 vote263 views1 answer
Is there a way to refer back to a previous line in python
Python
-1 vote257 views1 answer
Significant figures on axes plot matplotlib
Python
0 vote276 views3 answers
Pandas reading each xlsx file in folder
Python