列操作——创建与重命名列
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.____