/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 vote278 views1 answer
Hebrew range
Python
0 vote339 views1 answer
Python, read_csv from string
Python
0 vote288 views1 answer
Pandas dataframe from array of dict
Python
0 vote321 views1 answer
Python print to string
Python
0 vote332 views1 answer
Python odbc access database
Python
0 vote294 views1 answer
No default language could be detected for django app
Python
0 vote314 views1 answer
Python code to convert all keys of dict into lowercase
Python
0 vote310 views1 answer
Create table numpy
Python
5 votes319 views2 answers
Python if defined
Python
18 votes293 views1 answer
How to get directory path in python
Python