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

1 vote127 views1 answer
How to add to hashmap python
Python
1 vote135 views1 answer
Matplotlib latex non italic indices
Python
2 votes134 views1 answer
How to return PIL image from opencv
Python
0 vote149 views1 answer
Truncatechars django
Python
71 votes123 views4 answers
Saving a pandas dataframe as a csv
Python
13 votes124 views3 answers
Python memory usage
Python
22 votes117 views6 answers
How to install pygame in python
Python
2 votes90 views1 answer
Sqlalchemy check if db exists
Python
6 votes134 views1 answer
Django model form
Python
0 vote152 views1 answer
Django order by foreign key count
Python Django