/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

6 votes251 views2 answers
Python config file
Python
0 vote186 views1 answer
Reddit python 3 time a python program
Python
0 vote196 views2 answers
Remove vowels in a string python
Python
20 votes277 views3 answers
Matplotlib custom legend
Python
0 vote194 views2 answers
Numpy array into tuple
Python
0 vote180 views1 answer
Flask debugtoolbar
Python
1 vote206 views1 answer
User matching query does not exist. django
Python
0 vote245 views1 answer
Celery beat command for django celery beat
Python Django
95 votes295 views6 answers
How to use a for loop in python
Python
0 vote209 views1 answer
Python - matching people based on city
Python