/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

0 vote211 views1 answer
Get flask version
Python Flask
9 votes158 views3 answers
Pyramid pattern in python
Python
1 vote219 views1 answer
Python rsa
Python
-3 votes110 views2 answers
Detect text in image opencv
Python
0 vote192 views1 answer
Django today date in template
Python Django
0 vote156 views1 answer
How to extract dictionary value from string in python
Python
0 vote140 views1 answer
Ansible playbook to set passwordless sudo
Python
4 votes147 views1 answer
Get href bs4
Python
0 vote162 views1 answer
Datetime column only extract date pandas
Python
0 vote252 views1 answer
From numpy to list python
Python