/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

3 votes220 views2 answers
Return df.iloc[1:]
Python
0 vote194 views1 answer
Train_test_split without shuffle
Python
3 votes221 views2 answers
Check if a variable is empty python
Python
1 vote201 views1 answer
How to make a hidden file in python
Python
0 vote208 views1 answer
Pandas df trim columns if too much missing data
Python
4 votes233 views3 answers
Plt vertical line
Python
0 vote204 views1 answer
Postgresql backup using python
Python
4 votes215 views1 answer
Numpy mean 2 arrays
Python
0 vote204 views3 answers
Join list with comma python
Python
0 vote208 views1 answer
Slicing tuples
Python