Spaltenoperationen mit Handelsvolumina

Die Anzahl der in einem bestimmten Zeitraum gehandelten (verkauften oder gekauften) Aktien ist das Volumen. Du arbeitest als Business Analyst bei einer Börsenmaklerfirma. Eine Matrix mit täglichen Änderungen des Volumens, mat_stocks, steht dir zur Verfügung. Jede Spalte enthält die Veränderung des Volumens einer Aktie im Vergleich zum Vortag. Du möchtest herausfinden, ob das gehandelte Volumen dieser Aktien über einen gegebenen Zeitraum kontinuierlich zunimmt.

Die Funktion calculate_runs() steht dir zur Verfügung. Diese Funktion nimmt zwei Argumente: 1) die täglichen Volumenänderungen, 2) einen Einzelwert für den Zeitraum (Anzahl der Tage), für den der Run berechnet werden soll.

Du musst calculate_runs() parallel auf jede Spalte von mat_stocks anwenden und fünf Tage als Zeitraum angeben. Das Paket parallel wurde für dich geladen.

Diese Übung ist Teil des Kurses

Paralleles Programmieren in R

Kurs anzeigen

Anleitung zur Übung

Exportiere n_days an den Cluster.
Wende calculate_runs auf jede Spalte der Matrix mat_stocks an.
Gib den Wert für das Argument period mit n_days an.

Interaktive Übung

Vervollständige den Beispielcode, um diese Übung erfolgreich abzuschließen.

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

Code bearbeiten und ausführen