Операции со столбцами объёмов торгов

Объём торгов — это количество акций, купленных или проданных за определённый период. Вы работаете бизнес-аналитиком в брокерской компании. В вашем распоряжении есть матрица суточных изменений объёма торгов mat_stocks. Каждый столбец содержит изменение объёма по одной акции относительно предыдущего дня. Вам нужно выяснить, устойчиво ли растёт объём торгов по этим акциям за заданный период.

Для вас доступна функция calculate_runs(). Она принимает два аргумента: 1) суточные изменения объёма и 2) период (количество дней), для которого рассчитывается серия.

Необходимо применить calculate_runs() к каждому столбцу матрицы mat_stocks параллельно, указав период в пять дней. Пакет parallel уже подключён.

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

Параллельное программирование на R

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

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

Экспортируйте n_days в кластер.
Примените calculate_runs к каждому столбцу матрицы mat_stocks.
Укажите значение аргумента period, передав n_days.

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

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

n_days <- 5
cl <- makeCluster(4)

# Export n_days to cluster
clusterExport(cl, "___", envir = environment())
# Apply calculate_runs to each column of mat_stocks
volume_runs <- ___(___, ___, ___,
                   # Specify value for period argument
                   ___ = ___)

stopCluster(cl)

print(paste0("Number of ", n_days, "-day increasing runs: ", sum(volume_runs)))

Редактировать и запускать код