开始使用免费开始使用

连接 DataFrame

接下来的两个章节中,您将基于我们一直使用的航班数据构建一个模型,用来预测航班是否会延误。该模型还会包含执飞航线的飞机信息,所以第一步需要把两张表连接起来:flightsplanes

本练习是课程的一部分

PySpark 基础

查看课程

练习说明

  • 首先,将 planesyear 列重命名为 plane_year,以避免重复的列名。
  • 使用 tailnum 列作为键,将 flights 表与 planes 进行连接,创建一个名为 model_data 的新 DataFrame。

交互式实操练习

通过完成这段示例代码来试试这个练习。

# Rename year column
planes = planes.withColumnRenamed(____)

# Join the DataFrames
model_data = flights.join(____, on=____, how="leftouter")
编辑并运行代码