Operazioni per colonna con i volumi di trading

Il numero di azioni scambiate (vendute o acquistate) in un dato periodo è il volume. Lavori per una società di intermediazione come Business Analyst. Hai a disposizione una matrice delle variazioni giornaliere di volume, mat_stocks. Ogni colonna contiene la variazione di volume di un titolo rispetto al giorno precedente. Vuoi capire se il volume scambiato per questi titoli aumenta con costanza in un dato periodo.

La funzione calculate_runs() è a tua disposizione. Questa funzione accetta due argomenti: 1) le variazioni giornaliere di volume, 2) un valore singolo del periodo (numero di giorni) per cui calcolare la run.

Devi applicare calculate_runs() a ogni colonna di mat_stocks in parallelo, specificando cinque giorni come periodo. Il pacchetto parallel è già stato caricato per te.

Questo esercizio fa parte del corso

Programmazione parallela in R

Visualizza il corso

Istruzioni dell'esercizio

Esporta n_days nel cluster.
Applica calculate_runs a ciascuna colonna della matrice mat_stocks.
Specifica il valore per l'argomento period usando n_days.

Esercizio pratico interattivo

Prova a risolvere questo esercizio completando il codice di esempio.

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

Modifica ed esegui il codice