/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

20 votes255 views6 answers
Drop a column from dataframe
Python
1 vote256 views2 answers
Input spaces seperated integers in python
Python
3 votes279 views2 answers
Multiple Regression in Python
Python
0 vote293 views1 answer
Python simple number formatting samples
Python
0 vote250 views1 answer
When converting from dataframe to list delete nan values
Python
40 votes336 views5 answers
Python print list as string
Python
3 votes268 views1 answer
Pandas load txt database
Python
0 vote265 views1 answer
How to get all distinct substrings in a string python
Python
0 vote291 views1 answer
Instal django impoer expor
Python Django
32 votes253 views3 answers
Read csv python pandas plot
Python