Operace se sloupci obchodních objemů

Počet akcií zobchodovaných (prodaných nebo koupených) za dané časové období se nazývá objem. Pracuješ v makléřské firmě jako business analytik. K dispozici máš matici mat_stocks s denními změnami objemu. Každý sloupec obsahuje změnu objemu pro jednu akcii oproti předchozímu dni. Chceš zjistit, zda obchodovaný objem těchto akcií po dané období soustavně roste.

Máš k dispozici funkci calculate_runs(), která přijímá dva argumenty: 1) denní změny objemu, 2) hodnotu délky období (počet dní), pro které se výpočet provede.

Funkci calculate_runs() potřebuješ paralelně aplikovat na každý sloupec matice mat_stocks a jako období zadat pět dní. Balíček parallel je již načtený.

Toto cvičení je součástí kurzu

Paralelní programování v R

Zobrazit kurz

Pokyny k cvičení

Exportuj n_days do clusteru.
Aplikuj calculate_runs na každý sloupec matice mat_stocks.
Zadej hodnotu argumentu period pomocí n_days.

Interaktivní cvičení na vyzkoušení si v praxi

Vyzkoušejte si toto cvičení dokončením tohoto ukázkového kódu.

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

Upravit a spustit kód