/Python/Merge the values for each key using an associative and commutative reduce function.

Merge the values for each key using an associative and commutative reduce function.

Merge the values for each key using an associative and commutative reduce function.

from operator import add
rdd = sc.parallelize([("a", 1), ("b", 1), ("a", 1)])
sorted(rdd.reduceByKey(add).collect())
# [('a', 2), ('b', 1)]

0

Source: spark.apache.org

Similar codes

72 votes112 views4 answers
Check python version mac
Python
0 vote121 views2 answers
How to make an instagram report bot python
Python
6 votes120 views3 answers
Flask get ip of user
Python
0 vote77 views1 answer
How to sort subset of rows in pandas df
Python
21 votes114 views5 answers
Python exception
Python
-2 votes127 views1 answer
Stats.norm.cdf(2,loc=mean, scale=std_dev)
Python
-1 vote111 views1 answer
Check runtime python
Python
1 vote134 views1 answer
Require http method django view
Python Django
9 votes171 views2 answers
Post request with proxy python
Python
0 vote138 views1 answer
Print greeting in python explication
Python

Share