1. Apprendre
  2. /
  3. Cours
  4. /
  5. Introduction à Spark avec sparklyr en R

Connected

Exercice

Modifier des colonnes

Cela peut vous surprendre, mais bien des jeux de données ne sont pas parfaitement propres au départ ! Vous devez souvent corriger des valeurs ou créer de nouvelles colonnes à partir des données existantes. Dans la terminologie de dplyr, le processus qui consiste à modifier ou ajouter des colonnes s'appelle une « mutation » et s'effectue avec mutate(). Cette fonction prend un tibble et des arguments nommés pour mettre à jour des colonnes. Le nom de chaque argument correspond au nom de la colonne à modifier ou à ajouter, et sa valeur est une expression qui indique comment la mettre à jour. Par exemple, pour un tibble avec les colonnes x et y, le code suivant mettrait à jour x et créerait une nouvelle colonne z.

a_tibble %>%
  mutate(
    x = x + y,
    z = log(x)  
  )

Au cas où le message ne serait pas encore clair : les fonctions de base R ne fonctionnent pas avec les tibbles Spark. Vous ne pouvez donc pas utiliser within() ni transform() à cette fin.

Instructions

100 XP

Une connexion Spark a été créée pour vous sous le nom spark_conn. Un tibble relié aux métadonnées des pistes stockées dans Spark a été préalablement défini sous le nom track_metadata_tbl.

  • Sélectionnez les champs title et duration. Notez que les durées sont en secondes.
  • Faites passer le résultat à mutate() pour créer un nouveau champ, duration_minutes, qui contient la durée de la piste en minutes.