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

4 votes336 views1 answer
To_csv without index
Python
0 vote377 views2 answers
How to make list every 100 numbers in python
Python
0 vote315 views1 answer
Create line in canvas widget object
Python
1 vote360 views1 answer
Get text from url python last slash
Python
0 vote338 views1 answer
Get attribute of timestamp python
Python
2 votes326 views1 answer
Filter by row contains pandas
Python
0 vote329 views1 answer
Escape sequence in python
Python
2 votes344 views1 answer
Input two numbers in python in a single line
Python
0 vote339 views1 answer
Newick string python
Python
0 vote311 views1 answer
Groovey set variable
Python