Операции со столбцами — создание и переименование
Набор данных census всё ещё отображает не совсем то, что нам нужно. Давайте создадим новый вычисляемый столбец на основе существующих данных и переименуем его для наглядности.
Напомним: в вашем рабочем пространстве уже доступна SparkSession с именем spark!
Это упражнение является частью курса
Введение в PySpark
Инструкции к упражнению
- Создайте новый столбец
"weekly_salary", разделив значения столбца"income"на 52. - Переименуйте столбец
"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.____