/Python/Group the values for each key in the RDD into a single sequence.

Group the values for each key in the RDD into a single sequence.

rdd = sc.parallelize([("a", 1), ("b", 1), ("a", 1)])
sorted(rdd.groupByKey().mapValues(len).collect())
# [('a', 2), ('b', 1)]
sorted(rdd.groupByKey().mapValues(list).collect())
# [('a', [1, 1]), ('b', [1])]

Source: spark.apache.org

Similar codes

-1 vote343 views2 answers
Shell script to convert yaml
Python
0 vote330 views1 answer
Reveal a defined function in python
Python
2 votes340 views1 answer
Write custom query odoo
Python
3 votes375 views1 answer
Remove all occurrences of a character in a list python
Python
-1 vote335 views1 answer
How to fix speech recognition in python
Python
0 vote316 views1 answer
Rest api error
Python
2 votes371 views1 answer
Python set a specific datetime
Python
0 vote377 views1 answer
David dobrik
Python
1 vote321 views1 answer
Python check if variables are the same
Python
61 votes340 views3 answers
How to make python remove the duplicates in list
Python