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

0 vote264 views1 answer
'jet' is not a registered namespace
Python
0 vote404 views2 answers
How to close a flask web server with python
Python Flask
2 votes364 views2 answers
Python django query
Python Django
0 vote350 views1 answer
Decode in django templates
Python Django
10 votes275 views3 answers
Gson
Python
0 vote263 views1 answer
Javascript parse url with values and anchors
Python
0 vote264 views1 answer
Loaves
Python
0 vote279 views1 answer
Pandas 3d tutorail pythoin
Python
0 vote362 views1 answer
Jupyter notebook set password
Python
0 vote322 views2 answers
Python file is writable
Python