/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 vote120 views1 answer
S=0 def sum(x,y): n=int(input("enter no. of terms") for i in range(n): l=int(input("enter no.")) s=s+l print(s) sum()
Python
0 vote134 views3 answers
How to improve accuracy of random forest classifier
Python
37 votes133 views6 answers
How to convert list into string in python
Python
16 votes132 views3 answers
Python empty text file
Python
1 vote144 views1 answer
ValueError: There may be at most 1 Subject headers in a message
Python
0 vote127 views1 answer
How to check current version of library in python
Python
1 vote121 views1 answer
How to append data to csv file in python without replacing the already present text
Python
1 vote115 views1 answer
Dashes seaborn
Python
3 votes106 views5 answers
Pandas split column into multiple columns
Python
5 votes122 views1 answer
Input command in python shell
Python