/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

4 votes122 views4 answers
Python hex
Python
1 vote176 views1 answer
Django get form id from request
Python Django
0 vote141 views1 answer
Python dataframe appendisnt showing
Python
3 votes133 views1 answer
Python substitute multiple letters
Python
9 votes122 views1 answer
Drop last row pandas
Python
1 vote133 views1 answer
Why do we use graphs?
Python
2 votes134 views2 answers
Coding the fibonacci sequence
Python
30 votes273 views6 answers
Django static files
Python Django
1 vote126 views1 answer
Hcf program in python
Python
0 vote121 views1 answer
How to uninstall python-dotenv
Python