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 vote155 views1 answer
Find total no of true in a list in python
Python
1 vote168 views1 answer
RuntimeError: Attempting to deserialize object on a CUDA device but torch.cuda.is_available()
Python
6 votes178 views2 answers
Docker flask
Python Flask
2 votes170 views1 answer
Remove duplicates based on two columns in dataframe
Python
0 vote168 views1 answer
Regrid ntdcf file usig xarray
Python
2 votes156 views1 answer
Set django static root
Python
0 vote158 views1 answer
Using pickle to create binary files
Python
2 votes163 views1 answer
Random date python
Python
0 vote165 views1 answer
Boto3 read excel file from s3 into pandas
Python
0 vote190 views1 answer
Pandas description of dataframe renaming column values
Python