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

3 votes257 views1 answer
SSL: CERTIFICATE_VERIFY_FAILED with Python3
Python
0 vote317 views1 answer
Extends template django file system
Python Django
1 vote285 views1 answer
How to lock writing to a variable thread python
Python
0 vote252 views1 answer
2 - 20 python
Python
0 vote271 views1 answer
Python find oldest and newest date
Python
0 vote263 views1 answer
Explain the use of return keyword python
Python
0 vote247 views1 answer
Pandas dataframe row names
Python
5 votes242 views3 answers
How to add button in tkinter
Python
-2 votes249 views1 answer
Youtube dl python
Python
10 votes246 views1 answer
Https://docs.djangoproject.com/en/2.0/howto/static-files/
Python