Operacje na kolumnach – tworzenie i zmiana nazw
Zbiór danych census nadal nie wyświetla wszystkiego, czego potrzebujesz. Dodaj nową, syntetyczną kolumnę na podstawie istniejących danych, a następnie zmień jej nazwę dla większej przejrzystości.
Pamiętaj, że w twoim środowisku pracy dostępna jest już sesja SparkSession o nazwie spark!
To ćwiczenie jest częścią kursu
Wprowadzenie do PySpark
Instrukcje do ćwiczenia
- Utwórz nową kolumnę
"weekly_salary", dzieląc kolumnę"income"przez 52. - Zmień nazwę kolumny
"age"na"years". - Wyświetl wynikowy DataFrame.
Interaktywne ćwiczenie praktyczne
Spróbuj tego ćwiczenia, uzupełniając ten przykładowy kod.
# 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.____