rdd = sc.parallelize([2.0, 5.0, 43.0, 10.0]) rdd.min() # 2.0 rdd.min(key=str) # 10.0
rdd = sc.parallelize([1.0, 5.0, 43.0, 10.0]) rdd.max() # 43.0 rdd.max(key=str) # 5.0