Příklad with when()
Klauzule when() ti umožňuje podmíněně upravit DataFrame podle jeho obsahu. Přidáš do DataFramu voter_df náhodné číslo pro každého člena hlasování, který má titul "Councilmember".
DataFrame voter_df je již definovaný a máš ho k dispozici. Knihovna pyspark.sql.functions je dostupná jako F. Pro vygenerování náhodné hodnoty použij F.rand().
Toto cvičení je součástí kurzu
Cleaning Data with PySpark
Pokyny k cvičení
- Přidej do
voter_dfsloupecrandom_vals výsledky metodyF.rand()pro každého voliče s titulem Councilmember. - Zobraz několik řádků DataFramu a ověř, jestli klauzule
.when()fungovala správně.
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 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.____