CommencerCommencer gratuitement

Opérations par colonne avec les volumes échangés

Le nombre d’actions échangées (vendues ou achetées) sur une période donnée correspond au volume. Vous travaillez comme Business Analyst dans une société de courtage. Une matrice des variations quotidiennes de volume, mat_stocks, est à votre disposition. Chaque colonne contient l’évolution du volume d’une action par rapport à la veille. Vous voulez savoir si le volume échangé pour ces actions augmente de manière régulière 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 indiquant 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 spécifiant une période de cinq jours. Le package parallel a été chargé pour vous.

Cet exercice fait partie du cours

Programmation parallèle en R

Afficher le cours

Instructions

  • Exportez n_days vers le cluster.
  • 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 cet exemple de code.

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