CommencezCommencez gratuitement

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

Voir le cours

Instructions de l’exercice

  • Chargez le fichier JSON adults.json.
  • Filtrez les données pour ne garder que les adultes dont age est 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
____
Modifier et exécuter le code