Exemple de when()
La clause when() vous permet de modifier conditionnellement un DataFrame en fonction de son contenu. Vous allez modifier notre DataFrame voter_df pour ajouter un nombre aléatoire à tout membre votant dont le poste est « Councilmember ».
Le DataFrame voter_df est défini et à votre disposition. La bibliothèque pyspark.sql.functions est disponible sous F. Vous pouvez utiliser F.rand() pour générer une valeur aléatoire.
Cette activité fait partie du cours
Nettoyer des données avec PySpark
Instructions de l’exercice
- Ajoutez une colonne à
voter_dfnomméerandom_valavec les résultats de la méthodeF.rand()pour tout électeur ayant le titre Councilmember. - Affichez quelques lignes du DataFrame et vérifiez si la clause
.when()a fonctionné.
Exercice interactif pratique
Essayez cet exercice en complétant ce code d’exemple.
# 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.____