Return an RDD of grouped items.

rdd = sc.parallelize([1, 1, 2, 3, 5, 8])
result = rdd.groupBy(lambda x: x % 2).collect()
sorted([(x, sorted(y)) for (x,y) in result])
# [(0, [2, 8]), (1, [1, 1, 3, 5])]

Source: spark.apache.org

Similar codes

0 vote209 views1 answer
Concatenate dataframes using one column
Python
3 votes175 views1 answer
How to make a empty folder using os in pyhon
Python
14 votes296 views5 answers
How to create requirements.txt django
Python Django
0 vote228 views1 answer
Long type python
Python
0 vote200 views1 answer
Prettify json in pycharm
Python
0 vote209 views1 answer
Program for length of the shortest word
Python
0 vote207 views1 answer
Saving a copy of rcParams settings.
Python
0 vote201 views1 answer
Python - Cara Bermain Mp3 File
Python
4 votes188 views3 answers
Print bold python
Python
0 vote190 views1 answer
Encoding int to chr in python and vice versa
Python