НачатьНачать бесплатно

Изменение столбцов

Возможно, это вас удивит, но не все наборы данных изначально идеально упорядочены! Зачастую значения приходится корректировать или создавать новые столбцы на основе уже существующих данных. В терминологии dplyr процесс изменения и добавления столбцов называется мутацией и выполняется с помощью функции mutate(). Она принимает тиббл и именованные аргументы для обновления столбцов. Имя каждого аргумента соответствует названию столбца, который нужно изменить или добавить, а значение — выражению, описывающему способ обновления. Например, для тиббла со столбцами x и y следующий код обновит x и создаст новый столбец z.

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

Если вы ещё не убедились в том, что базовые функции R не работают со Spark-тибблами, напомним: для этих целей нельзя использовать within() или transform().

Это упражнение является частью курса

Введение в Spark с sparklyr на R

Посмотреть курс

Инструкции к упражнению

Подключение к Spark уже создано и доступно как spark_conn. Тиббл, связанный с метаданными треков в Spark, предопределён как track_metadata_tbl.

  • Выберите поля title и duration. Обратите внимание, что продолжительность указана в секундах.
  • Передайте результат через конвейер в mutate(), чтобы создать новое поле duration_minutes, содержащее продолжительность трека в минутах.

Интерактивное практическое упражнение

Попробуйте выполнить это упражнение, дополнив этот пример кода.

# track_metadata_tbl has been pre-defined
track_metadata_tbl

# Manipulate the track metadata
track_metadata_tbl %>%
  # Select columns
  ___ %>%
  # Mutate columns
  ___
Редактировать и запускать код