When / Otherwise

Tento úkol je podobný předchozímu, ale tentokrát chceš přidat různé hodnoty podle pozice voliče. Uprav DataFrame voter_df tak, aby se ke každému členovi označenému jako Councilmember přidalo náhodné číslo. Pro Mayor použij hodnotu 2 a pro jakoukoli jinou pozici hodnotu 0.

DataFrame voter_df je k dispozici. Knihovna pyspark.sql.functions je dostupná pod aliasem F.. Náhodnou hodnotu vygeneruješ pomocí F.rand().

Toto cvičení je součástí kurzu

Cleaning Data with PySpark

Zobrazit kurz

Pokyny k cvičení

Přidej do voter_df sloupec random_val, který bude obsahovat výsledek metody F.rand() pro každého voliče s titulem Councilmember. Pro Mayor nastav random_val na hodnotu 2. Pro všechny ostatní tituly nastav hodnotu 0.
Zobraz několik řádků DataFramu a ověř, jestli klauzule fungovaly správně.
Pomocí klauzule .filter vyhledej řádky s hodnotou 0 ve sloupci random_val.

Interaktivní cvičení na vyzkoušení si v praxi

Vyzkoušejte si toto cvičení dokončením tohoto ukázkového kódu.

# 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()

Upravit a spustit kód