/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

2 votes303 views3 answers
Combine list of dicts
Python
0 vote309 views1 answer
Urllib.error.HTTPError: HTTP Error 502 docker redis
Python
1 vote299 views1 answer
Rangoli in python
Python
5 votes316 views2 answers
Df.shape 0
Python
-1 vote316 views6 answers
List comprehension python
Python
-1 vote345 views2 answers
This code is supposed to display "2 + 2 = 4" on the screen, but there is an error. Find the error in the code and fix it, so that the output is correct.
Python
225 votes596 views6 answers
Import random python
Python
-1 vote340 views1 answer
How to check if string ends with specific characters in python
Python
0 vote283 views1 answer
Train chatterbot using yml
Python
0 vote294 views1 answer
Cartpole dqn reward max is 200
Python