spark中的sortBy用法

在Spark中，`sortBy`是一个对RDD进行排序的操作，它可以按照指定的排序键对RDD中的元素进行排序。

`sortBy`的使用方法如下：

sorted_rdd = rdd.sortBy(lambda x: x, ascending=True, numPartitions=None)

其中，`x`是排序键，`ascending`表示是否升序排列，默认为True，`numPartitions`表示分区数。

下面是一个例子：

rdd = sc.parallelize([5, 1, 3, 2, 4])
sorted_rdd = rdd.sortBy(lambda x: x)
print(sorted_rdd.collect())

输出结果为：

[1, 2, 3, 4, 5]

在这个例子中，我们首先创建了一个RDD，然后使用`sortBy`按照元素的大小进行排序，最后输出了排序后的结果。

注意，`sortBy`操作会返回一个新的RDD，原始的RDD并不会被修改。