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

11 votes109 views2 answers
How to push item to array python
Python
0 vote111 views1 answer
How to use idl in python
Python
2 votes107 views2 answers
How to use google translate api in python
Python
3 votes108 views2 answers
Python file location path
Python
1 vote102 views1 answer
How to clear checkbox in tkinter
Python
0 vote130 views1 answer
Dataframe summarize how many in each column
Python
-1 vote114 views3 answers
Blockchain.py
Python
0 vote119 views1 answer
Python how to make boxplots with swarmplot
Python
82 votes112 views6 answers
Python version command
Python
0 vote118 views1 answer
Dividing counter object in python
Python