/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

0 vote176 views1 answer
How to make a random int in python
Python
1 vote161 views1 answer
Count number of repeats in list python
Python
23 votes243 views6 answers
Average python
Python
0 vote169 views1 answer
File "main.py", line 11 if message.author == client.user: ^ IndentationError: expected an indented block
Python
7 votes207 views2 answers
How to get index of pandas dataframe python
Python
0 vote171 views1 answer
How to test that an exception was raise using pytest
Python
6 votes167 views6 answers
Python ide
Python
10 votes170 views1 answer
How do i convert a list to a string in python
Python
1 vote163 views1 answer
Python your mom
Python
0 vote174 views1 answer
Append time complexity python
Python