Операції над стовпцями з обсягами торгів

Кількість акцій, проданих або куплених за певний період, — це обсяг. Ви працюєте бізнес-аналітиком у брокерській компанії. Для вас доступна матриця щоденних змін обсягів, 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)))

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