/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 vote212 views1 answer
Python lane angle detection
Python
0 vote229 views1 answer
Find a file in python
Python
13 votes248 views5 answers
Convert column to numeric pandas
Python
0 vote217 views1 answer
All Combinations
Python
0 vote209 views1 answer
Matlab filter in python
Python
0 vote193 views1 answer
Sys executable juypter is incorrect visual code
Python
2 votes217 views2 answers
What is role of ALLOWED_HOSTs in Django
Python Django
1 vote210 views1 answer
Ax tick params
Python
0 vote216 views1 answer
Dictionnaire
Python
7 votes207 views3 answers
Print variable in sentence python
Python