Operații pe coloane cu volume de tranzacționare

Numărul de acțiuni tranzacționate (vândute sau cumpărate) într-o perioadă dată reprezintă volumul. Lucrezi pentru o firmă de brokeraj ca Analist de Business. Ai la dispoziție o matrice a variațiilor zilnice de volum, mat_stocks. Fiecare coloană conține variația volumului față de ziua precedentă pentru o acțiune. Vrei să afli dacă volumul tranzacționat pentru aceste acțiuni crește constant pe o perioadă dată.

Funcția calculate_runs() este disponibilă pentru tine. Aceasta primește două argumente: 1) variațiile zilnice ale volumului și 2) o valoare unică pentru perioadă (numărul de zile) pentru care să se calculeze rulada.

Trebuie să aplici calculate_runs() fiecărei coloane a matricii mat_stocks în paralel, specificând cinci zile ca perioadă. Pachetul parallel a fost deja încărcat pentru tine.

Acest exercițiu face parte din cursul

Programare paralelă în R

Vezi cursul

Instrucțiuni pentru exercițiu

Exportă n_days către cluster.
Aplică calculate_runs fiecărei coloane a matricii mat_stocks.
Specifică valoarea pentru argumentul period cu n_days.

Exercițiu interactiv practic

Încearcă acest exercițiu completând acest cod de exemplu.

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

Editează și rulează codul