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 vote254 views1 answer
Update nested dictionary python
Python
0 vote269 views1 answer
Django-multivaluedictkeyerror-error
Python Django
30 votes250 views2 answers
How do i limit decimals to only two decimals in python
Python
17 votes235 views2 answers
Count lines in file python
Python
23 votes247 views2 answers
Converting month number to month name python
Python
0 vote267 views1 answer
Syntax of calloc
Python
1 vote233 views1 answer
Make csv lowercase python
Python
1 vote248 views2 answers
Adding numbers in python
Python
6 votes239 views1 answer
How to get the calendar of current month in python
Python
2 votes262 views2 answers
Import other python files
Python