/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 votes159 views1 answer
Python subprocess with environment variables
Python
3 votes150 views3 answers
Convert pyqt5 ui file to python file
Python
0 vote164 views1 answer
Open link in tab new trong selenium python
Python
0 vote157 views1 answer
Np arange shape
Python
6 votes149 views5 answers
Python concatenate dictionaries
Python
66 votes145 views6 answers
Python create folder
Python
7 votes151 views2 answers
What is numpy
Python
0 vote177 views1 answer
Pygame.event.get() in pygame
Python
0 vote193 views1 answer
Check django channels with redis setup
Python Django
1 vote154 views1 answer
Split string form url last slash
Python