使用scala/spark在排序的rdd中获取最大值

import org.apache.spark.{SparkConf, SparkContext}

object MaxValueInSortedRDD {
  def main(args: Array[String]): Unit = {
    val conf = new SparkConf().setAppName("MaxValueInSortedRDD").setMaster("local")
    val sc = new SparkContext(conf)

    // 创建一个排序的RDD
    val sortedRDD = sc.parallelize(Array(1, 2, 3, 4, 5, 6, 7, 8, 9, 10)).sortBy(x => x)

    // 获取最大值
    val maxValue = sortedRDD.max()

    println("最大值：" + maxValue)

    sc.stop()
  }
}