Déduire et filtrer
Imaginez que vous avez un jeu de données du recensement avec un en-tête et un schéma connus. Chargeons ce jeu de données et laissons PySpark déduire le schéma. Que voyez-vous si vous filtrez les adultes de plus de 40 ans?
Rappelez-vous qu'une SparkSession nommée spark est déjà disponible dans votre espace de travail!
Cette activité fait partie du cours
Introduction à PySpark
Instructions de l’exercice
- Chargez le fichier JSON
adults.json. - Filtrez les données pour ne garder que les adultes dont
ageest supérieur à40. - Affichez les résultats.
Exercice interactif pratique
Essayez cet exercice en complétant ce code d’exemple.
# Load the dataframe
census_df = spark.read.json("adults.json")
# Filter rows based on age condition
salary_filtered_census = census_df.____(census_df[____]____)
# Show the result
____