/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 vote149 views3 answers
A program that asks for the user's input of a list of numbers and sort it in reverse in python
Python
0 vote204 views1 answer
Error: Command '['/home/jonas/twitchslam/env/bin/python3.6', '-Im', 'ensurepip', '--upgrade', '--default-pip']' returned non-zero exit status 1.
Python
3 votes143 views1 answer
Accessing items of tuple in python
Python
3 votes137 views1 answer
How to time a python script
Python
0 vote146 views1 answer
Python read and delete line from file
Python
0 vote135 views1 answer
Chat bot in python
Python
0 vote161 views1 answer
Api.models.DoesNotExist: matching query does not exist
Python
4 votes190 views6 answers
Python cheat sheet
Python
1 vote151 views1 answer
Corona shape in python
Python
31 votes149 views4 answers
Python convert list of strings to list of integers
Python