Esempio di when()
La clausola when() ti permette di modificare in modo condizionale un DataFrame in base al suo contenuto. Qui dovrai modificare il DataFrame voter_df per aggiungere un numero casuale a ogni elettore il cui titolo è "Councilmember".
Il DataFrame voter_df è già definito e a tua disposizione. La libreria pyspark.sql.functions è disponibile come F. Puoi usare F.rand() per generare il valore casuale.
Questo esercizio fa parte del corso
Pulizia dei dati con PySpark
Istruzioni dell'esercizio
- Aggiungi una colonna a
voter_dfchiamatarandom_valcon il risultato del metodoF.rand()per qualsiasi elettore con il titolo Councilmember. - Mostra alcune righe del DataFrame, verificando se la clausola
.when()ha funzionato.
esercizio interattivo pratico
Prova questo esercizio completando questo codice di esempio.
# Add a column to voter_df for any voter with the title **Councilmember**
voter_df = voter_df.____('random_val',
____(____, ____))
# Show some of the DataFrame rows, noting whether the when clause worked
voter_df.____