When / Otherwise

Den här uppgiften liknar den förra, men nu vill du lägga till flera värden baserat på väljarens befattning. Modifiera din voter_df-DataFrame så att ett slumpmässigt tal läggs till för varje röstande medlem med titeln Councilmember. Använd 2 för Mayor och 0 för alla andra befattningar.

DataFrame:en voter_df är definierad och tillgänglig för dig. Biblioteket pyspark.sql.functions är tillgängligt som F.. Du kan använda F.rand() för att generera det slumpmässiga värdet.

Den här övningen är en del av kursen

Datarensning med PySpark

Visa kurs

Övningsinstruktioner

Lägg till en kolumn i voter_df med namnet random_val som innehåller resultatet av metoden F.rand() för alla väljare med titeln Councilmember. Sätt random_val till 2 för Mayor. Sätt alla andra titlar till värdet 0.
Visa några av raderna i DataFrame:en och kontrollera om satserna fungerade som förväntat.
Använd .filter-satsen för att hitta 0 i random_val.

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 a voter based on their position
voter_df = voter_df.____('random_val',
                               when(voter_df.TITLE == 'Councilmember', ____)
                               .____(____, 2)
                               ____

# Show some of the DataFrame rows
voter_df.show()

# Use the .filter() clause with random_val
voter_df.____(____).show()

Redigera och kör kod