合併這些 DataFrame
在接下來的兩個章節中,你會建立一個模型,根據我們一直在處理的航班資料來預測班機是否會延誤。這個模型也會納入執飛該航線的飛機資訊,因此第一步就是把兩張表 flights 與 planes 合併起來!
本練習屬於課程
PySpark 基礎
練習說明
- 先將
planes的year欄位重新命名為plane_year,以避免欄位名稱重複。 - 使用
tailnum欄位作為鍵,將flights與planes進行連接,建立一個名為model_data的新 DataFrame。
動手互動練習
試著完成這個範例程式碼,體驗一下這個練習。
# Rename year column
planes = planes.withColumnRenamed(____)
# Join the DataFrames
model_data = flights.join(____, on=____, how="leftouter")