欄位操作:建立與重新命名欄位
census 資料集還沒完全呈現出你想要的內容。讓我們以現有欄位為基礎新增一個合成欄位,並為了清楚起見把它重新命名。
記住,你的工作環境中已經有一個名為 spark 的 SparkSession!
本練習屬於課程
PySpark 入門
練習說明
- 以
"income"欄位除以 52,建立新欄位"weekly_salary"。 - 將
"age"欄位重新命名為"years"。 - 顯示產生的 DataFrame。
動手互動練習
試著完成這個範例程式碼,體驗一下這個練習。
# Create a new column 'weekly_salary'
census_df_weekly = census_df.____(____, ____)
# Rename the 'age' column to 'years'
census_df_weekly = ____.____(____, ____)
# Show the result
census_df_weekly.____