/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

13 votes248 views2 answers
How to know how much lines a file has using python
Python
0 vote247 views1 answer
Get param function python
Python
4 votes243 views2 answers
How to reinstall a python package
Python
0 vote260 views1 answer
Popup flutter
Python
0 vote267 views1 answer
Django is .get lazy
Python
0 vote233 views1 answer
Create a variable python
Python
0 vote242 views1 answer
No module named 'neat
Python
1 vote262 views2 answers
Middle value of a list in python
Python
1 vote189 views2 answers
Alpaca api python wrapper
Python
0 vote238 views1 answer
Extract only year from date python
Python