Thao tác theo cột với khối lượng giao dịch
Số cổ phiếu được giao dịch (bán hoặc mua) trong một khoảng thời gian nhất định gọi là khối lượng. Bạn đang làm Chuyên viên Phân tích Kinh doanh tại một công ty môi giới chứng khoán. Một ma trận về biến động khối lượng hằng ngày, mat_stocks, đã được chuẩn bị cho bạn. Mỗi cột chứa mức thay đổi khối lượng của một mã cổ phiếu so với ngày trước đó. Bạn muốn kiểm tra liệu khối lượng giao dịch của các mã này có tăng đều trong một giai đoạn nhất định hay không.
Hàm calculate_runs() đã có sẵn cho bạn. Hàm này nhận hai đối số: 1) biến động khối lượng hằng ngày, 2) một giá trị đơn cho giai đoạn (số ngày) để tính chuỗi tăng/giảm.
Bạn cần áp dụng calculate_runs() cho từng cột của mat_stocks theo kiểu song song, với giai đoạn là năm ngày. Gói parallel đã được nạp sẵn.
Bài tập này là một phần của khóa học
Lập trình song song trong R
Hướng dẫn bài tập
- Export
n_dayssang cụm (cluster). - Áp dụng
calculate_runscho từng cột của ma trậnmat_stocks. - Truyền giá trị cho đối số
periodbằngn_days.
Bài tập tương tác thực hành trực tiếp
Hãy thử làm bài tập này bằng cách hoàn thành đoạn mã mẫu này.
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)))