开始使用免费开始使用

列操作——创建与重命名列

census 数据集还没完全呈现出您想要的信息。让我们基于已有列创建一个新的合成列,并为清晰起见给它重命名。

请记住,您的工作区中已经有一个名为 sparkSparkSession

本练习是课程的一部分

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.____
编辑并运行代码