/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

2 votes150 views1 answer
Python download s3 image
Python
0 vote189 views1 answer
Python qt always on top
Python
23 votes156 views6 answers
Decorator python
Python
5 votes148 views5 answers
Minecraft tutorial
Python
0 vote167 views1 answer
How to add number in tuple
Python
1 vote142 views1 answer
How to append leading zeros in python
Python
0 vote144 views4 answers
Django-sslserver · PyPI
Python
1 vote138 views1 answer
How to custom page not found in django
Python
7 votes152 views3 answers
Lambda and function in python
Python
0 vote139 views1 answer
Creating a record in python
Python