when() 範例
when() 子句可讓你依據內容有條件地修改 DataFrame。請修改 voter_df DataFrame，對任何職稱為「Councilmember」的投票成員加上一個隨機數字。
voter_df DataFrame 已經定義並可供你使用。pyspark.sql.functions 函式庫已匯入為 F.。你可以使用 F.rand() 產生隨機值。
本練習屬於課程
使用 PySpark 清理資料
練習說明
- 在
voter_df中新增名為random_val的欄位，對職稱為 Councilmember 的投票者填入F.rand()的結果。 - 顯示部分 DataFrame 的列，確認
.when()子句是否如預期運作。
動手互動練習
試著完成這個範例程式碼，體驗一下這個練習。
# Add a column to voter_df for any voter with the title **Councilmember**
voter_df = voter_df.____('random_val',
____(____, ____))
# Show some of the DataFrame rows, noting whether the when clause worked
voter_df.____