spark中找出大数据基础考试成绩超过90分的学生ID，需要将得到的学生ID、成绩存到一个RDD中

在 Apache Spark 中，如果你有学生的考试成绩数据存储在一个DataFrame或RDD（如Spark SQL DataFrames或Resilient Distributed Datasets）中，你可以使用 `filter` 函数来筛选出成绩超过90分的学生，并通过 `map` 函数将学生ID提取出来。这里假设你有一个名为 `scores` 的DataFrame，其中包含 "student_id" 和 "score" 两个字段：

from pyspark.sql import SparkSession

# 创建SparkSession
spark = SparkSession.builder.getOrCreate()

# 筛选出成绩超过90分的学生
filtered_scores = scores.filter(scores['score'] > 90)

# 提取学生ID并转换成RDD
student_ids = filtered_scores.select('student_id').rdd.flatMap(lambda row: [row.student_id])

# 存储到新的RDD中
student_ids_rdd = student_ids.map(tuple)  # 如果你想以元组形式存储

这里我们首先过滤出满足条件的行，然后使用 `select` 操作选择 "student_id" 字段，再通过 `flatMap` 将每一行的学生ID列表化。最后，可能需要将结果转换为元组形式，因为某些Spark操作可能需要键值对的形式。