在apache spark JavaPairRDD中按键排序

import org.apache.spark.api.java.JavaPairRDD;
import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.api.java.JavaSparkContext;
import scala.Tuple2;

public class SparkSortByKeyExample {
    public static void main(String[] args) {
        // 创建SparkContext
        JavaSparkContext sparkContext = new JavaSparkContext("local", "SparkSortByKeyExample");

        // 创建一个包含键值对的JavaPairRDD
        JavaPairRDD<Integer, String> pairRDD = sparkContext.parallelizePairs(Arrays.asList(
                new Tuple2<>(3, "Apple"),
                new Tuple2<>(1, "Banana"),
                new Tuple2<>(2, "Orange")
        ));

        // 按键排序
        JavaPairRDD<Integer, String> sortedRDD = pairRDD.sortByKey();

        // 打印排序后的结果
        sortedRDD.foreach(tuple -> System.out.println(tuple._1() + ": " + tuple._2()));

        // 关闭SparkContext
        sparkContext.close();
    }
}