/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 vote285 views1 answer
Extract minutes from timedelta python
Python
1 vote263 views1 answer
Sdsdsdsdsddsdddsdsdsdsdsdsdsdsdsdsdsdsdsdssdsdsdsdsdsdsdssssssddsdssdssssdsdsdsdsdsdsdsdsdsdsdsdsdsdssdssdsdsdsdsdsdsdsdsdsdsdssd
Python
0 vote293 views2 answers
Read one column pandas
Python
6 votes311 views5 answers
How to count unique values in a column dataframe in python
Python
0 vote303 views1 answer
Doormat pattern
Python
3 votes267 views1 answer
How to time a python script
Python
34 votes303 views2 answers
Python shuffle list with seed
Python
0 vote274 views1 answer
Nibabel expand dimension
Python
2 votes333 views3 answers
Python beep
Python
29 votes306 views3 answers
'pipwin' is not recognized as an internal or external command
Python