Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- // 创建成绩数据
- val scores = sc.parallelize(Seq(
- ("Olivia", 95),
- ("Liam", 65),
- ("Emma", 88),
- ("Noah", 89),
- ("Ava", 50),
- ("Ethan", 93),
- ("Sophia", 78),
- ("Mason", 99),
- ("Isabella", 66),
- ("Lucas", 59)
- ))
- // 求出成绩前三名的同学
- val top3Students = scores.sortBy(_._2, ascending = false).take(3)
- println("Top 3 Students:")
- top3Students.foreach { case (name, score) =>
- println(s"$name: $score")
- }
- // 求出不及格的同学（成绩小于60分）
- val failedStudents = scores.filter(_._2 < 60).collect()
- println("Failed Students:")
- failedStudents.foreach { case (name, score) =>
- println(s"$name: $score")
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
