Opérations par colonne avec les volumes d'échanges

Le nombre d'actions échangées (vendues ou achetées) sur une période donnée correspond au volume. Vous travaillez comme analyste d'affaires dans une maison de courtage. Une matrice des variations quotidiennes de volume, mat_stocks, est à votre disposition. Chaque colonne contient la variation de volume d'un titre par rapport à la veille. Vous souhaitez déterminer si le volume échangé pour ces titres augmente de façon constante sur une période donnée.

La fonction calculate_runs() est disponible. Elle prend deux arguments : 1) les variations quotidiennes de volume, 2) une valeur unique représentant la période (nombre de jours) pour laquelle calculer la série.

Vous devez appliquer calculate_runs() à chaque colonne de mat_stocks en parallèle, en précisant cinq jours comme période. Le paquet parallel a été chargé pour vous.

Cette activité fait partie du cours

Programmation parallèle en R

Voir le cours

Instructions de l’exercice

Exportez n_days vers le grappe de calcul.
Appliquez calculate_runs à chaque colonne de la matrice mat_stocks.
Indiquez la valeur de l'argument period avec n_days.

Exercice interactif pratique

Essayez cet exercice en complétant ce code d’exemple.

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)))

Modifier et exécuter le code