Operații pe coloane – creare și redenumire
Setul de date census încă nu afișează tot ce ai nevoie. Hai să creăm o coloană sintetică nouă pe baza coloanelor existente și să o redenumim pentru mai multă claritate.
Amintește-ți că în spațiul tău de lucru există deja o SparkSession numită spark!
Acest exercițiu face parte din cursul
Introducere în PySpark
Instrucțiuni pentru exercițiu
- Creează o coloană nouă,
"weekly_salary", împărțind coloana"income"la 52. - Redenumește coloana
"age"în"years". - Afișează DataFrame-ul rezultat.
Exercițiu interactiv practic
Încearcă acest exercițiu completând acest cod de exemplu.
# 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.____