/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 vote226 views1 answer
How to become python developer
Python
0 vote194 views1 answer
Change python from 3.8 to 3.7
Python
2 votes190 views1 answer
Pandas get value not equal to
Python
2 votes210 views2 answers
How to open a website with selenium python
Python
0 vote207 views1 answer
How to take multiple input form python
Python
0 vote188 views1 answer
How to resume request downloads
Python
7 votes218 views3 answers
How to exit venv in python
Python
8 votes147 views4 answers
Python gui
Python
0 vote231 views1 answer
Increase colorbar ticksize
Python
0 vote201 views1 answer
TypeError: can't pickle weakref objects site:stackoverflow.com
Python