Изменение столбцов
Возможно, это вас удивит, но не все наборы данных изначально идеально упорядочены! Зачастую значения приходится корректировать или создавать новые столбцы на основе уже существующих данных. В терминологии 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
___