/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 vote115 views1 answer
How to implement ctrl + C in terminal by using code
Python
0 vote111 views1 answer
How to get the number in the tenths place of a integer in python
Python
0 vote110 views1 answer
Every second value python
Python
7 votes113 views1 answer
Tkinter give button 2 commands
Python
0 vote147 views2 answers
Distribution analysis pandas
Python
0 vote131 views1 answer
Windows 10 reset django migrations
Python
0 vote146 views1 answer
Dump ML Model
Python
4 votes117 views3 answers
Write a list into csv python
Python
32 votes110 views6 answers
If and else in python
Python
3 votes130 views1 answer
Plotly not showing in jupyter
Python