/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

9 votes130 views2 answers
Pandas to convert null values to mean in numeric column
Python
0 vote129 views1 answer
Python pickle 'ascii' codec can't decode byte 0x80 in position 0
Python
0 vote137 views2 answers
List comprehension with square numbers python
Python
0 vote121 views1 answer
Loop through list, find specific number and output element's index
Python
9 votes165 views5 answers
Get dummies pandas
Python
0 vote121 views1 answer
Pandas merge sort columns
Python
0 vote173 views1 answer
Make value of two tables unique django
Python Django
0 vote146 views1 answer
What is * in argument list in python
Python
0 vote136 views1 answer
Sqlite python select with parameters
Python
0 vote128 views1 answer
Assignment 7.1 python data structures
Python

Share