開始使用免費開始

合併這些 DataFrame

在接下來的兩個章節中,你會建立一個模型,根據我們一直在處理的航班資料來預測班機是否會延誤。這個模型也會納入執飛該航線的飛機資訊,因此第一步就是把兩張表 flightsplanes 合併起來!

本練習屬於課程

PySpark 基礎

檢視課程

練習說明

  • 先將 planesyear 欄位重新命名為 plane_year,以避免欄位名稱重複。
  • 使用 tailnum 欄位作為鍵,將 flightsplanes 進行連接,建立一個名為 model_data 的新 DataFrame。

動手互動練習

試著完成這個範例程式碼,體驗一下這個練習。

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

# Join the DataFrames
model_data = flights.join(____, on=____, how="leftouter")
編輯並執行程式碼