1. Learn
    2. /
  2. 课程
    3. /
  3. PySpark 入门
Connected

道练习

在 DataFrame 上运行 SQL

在 PySpark 中，您可以用 SQL 查询轻松操作 DataFrame。SparkSession 的 .sql() 方法允许以编程方式运行 SQL 查询，并将结果返回为另一个 DataFrame。在本练习中，您将把之前创建的一个 DataFrame 注册为临时表，然后编写查询，从该临时表中选出人员姓名，并将结果赋给一个新的 DataFrame。

请记住，您的工作区中已经有 SparkSession spark 和 DataFrame df 可用。

说明

100 XP
  • 由 df DataFrame 创建名为 "people" 的临时表。
  • 编写查询，从临时表 people 中选择人员姓名。
  • 将 Spark 查询的结果赋给名为 people_df_names 的新 DataFrame。
  • 打印 people_df_names DataFrame 中前 10 个姓名。