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

18 votes189 views6 answers
Python get last element of array
Python
5 votes223 views1 answer
How to override save method in django
Python Django
4 votes188 views1 answer
Check if an application is running python
Python
1 vote190 views1 answer
How to load wav file with python
Python
0 vote188 views1 answer
Display vowels in a string using for loop
Python
21 votes213 views1 answer
Python remove last characters from string
Python
0 vote155 views1 answer
Update cell in sheet by column name using pandas
Python
0 vote200 views1 answer
Codegrepper is cool
Python
0 vote136 views1 answer
Selenium.common.exceptions.elementclickinterceptedexception: message: element click intercepted:
Python
6 votes199 views3 answers
Python convert number to list of digits
Python