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

9 votes160 views1 answer
Drop the last row of a dataframe
Python
8 votes178 views4 answers
Python split sentence into words
Python
0 vote142 views1 answer
2 variables with statement python
Python
2 votes168 views1 answer
Sum all values of a dictionary python
Python
3 votes185 views1 answer
Sort two lists by one python
Python
13 votes135 views4 answers
How to call a python script from another python script
Python
1 vote168 views2 answers
Python file basename
Python
4 votes187 views1 answer
Skip to next iteration in for loop python
Python
3 votes134 views4 answers
List in pythom
Python
-1 vote130 views1 answer
C is better than python
Python