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.____