如何在Spark中对分区的内容进行排序？

# 导入必要的模块
from pyspark import SparkContext

# 创建SparkContext对象
sc = SparkContext("local", "Sorting Partitions")

# 创建一个示例数据集
data = sc.parallelize([(1, "apple"), (3, "banana"), (2, "orange"), (4, "grape")])

# 重新分区
repartitioned_data = data.repartition(2)

# 对每个分区中的数据进行排序
sorted_data = repartitioned_data.mapPartitions(lambda partition: sorted(partition, key=lambda x: x[0]))

# 合并排序后的数据
result = sorted_data.flatMap(lambda x: x)

# 打印结果
print(result.collect())