/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 vote315 views1 answer
Pygame image get height
Python
3 votes319 views2 answers
To extract out only year month from a date column in pandas
Python
0 vote328 views1 answer
How to make loops in python
Python
0 vote313 views2 answers
Is vowel python
Python
0 vote362 views1 answer
Fibonacci series in python using for loop
Python
1 vote339 views1 answer
Convert dtype of column cudf
Python
1 vote294 views1 answer
Key down python
Python
9 votes354 views1 answer
Cannot acess stylesheets in static files
Python
0 vote377 views1 answer
Solidity compiler for python
Python
0 vote363 views1 answer
Make large 3d plot in python
Python