Exempel på when()
Klausulen when() låter dig villkorligt modifiera en DataFrame baserat på dess innehåll. Du ska modifiera DataFrame:en voter_df för att lägga till ett slumptal för varje röstande medlem med titeln "Councilmember".
DataFrame:en voter_df är definierad och tillgänglig. Biblioteket pyspark.sql.functions är tillgängligt som F. Du kan använda F.rand() för att generera slumpvärdet.
Den här övningen är en del av kursen
Datarensning med PySpark
Övningsinstruktioner
- Lägg till en kolumn i
voter_dfmed namnetrandom_valsom innehåller resultatet av metodenF.rand()för varje väljare med titeln Councilmember. - Visa några av DataFrame:ens rader och kontrollera om
.when()-klausulen fungerade som förväntat.
Interaktiv övning med praktiskt arbete
Testa den här övningen genom att slutföra den här exempelkoden.
# 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.____