/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 vote358 views1 answer
Wifite subsystem
Python
2 votes367 views4 answers
How to read second sheets of excel using python
Python
0 vote379 views1 answer
How to correlation with axis in pandas
Python
1 vote347 views2 answers
Python read and write pdf data
Python
0 vote308 views1 answer
Python dictionary get vs setdefault
Python
1 vote371 views1 answer
For loop django template count
Python Django
0 vote426 views1 answer
Extends template django file system
Python Django
-1 vote366 views1 answer
Django email verification
Python Django
0 vote373 views1 answer
Python split() source code
Python
0 vote351 views1 answer
Gnome-shell turn off
Python