Scala RDD按组获取最早日期

import java.text.SimpleDateFormat
import java.util.Date

// 创建一个样例类，表示数据记录
case class Record(id: Int, date: Date)

// 创建一个RDD，包含多个Record对象
val rdd = sparkContext.parallelize(Seq(
  Record(1, new SimpleDateFormat("yyyy-MM-dd").parse("2022-01-01")),
  Record(2, new SimpleDateFormat("yyyy-MM-dd").parse("2022-01-03")),
  Record(3, new SimpleDateFormat("yyyy-MM-dd").parse("2022-01-02")),
  Record(4, new SimpleDateFormat("yyyy-MM-dd").parse("2022-01-01")),
  Record(5, new SimpleDateFormat("yyyy-MM-dd").parse("2022-01-02"))
))

// 按照日期进行分组
val groupedRDD = rdd.groupBy(record => record.date)

// 对每个分组，获取日期最早的数据
val earliestDatesRDD = groupedRDD.mapValues(records => records.minBy(_.date))

// 打印结果
earliestDatesRDD.collect().foreach(println)