按列处理交易量
在给定时间段内交易（卖出或买入）的股票数量称为成交量。您在一家证券经纪公司担任业务分析师。系统已为您提供每日成交量变动的矩阵 mat_stocks。每一列表示某只股票相较前一日的成交量变化。您希望判断这些股票在给定区间内的成交量是否持续上升。
函数 calculate_runs() 可直接使用。该函数需要两个参数：1）每日成交量的变化；2）用于计算连续上升段的周期长度（天数）的单个数值。
您需要将 calculate_runs() 并行应用到 mat_stocks 的每一列上，并将周期设为 5 天。parallel 包已为您加载。
本练习是课程的一部分
R 并行编程
练习说明
- 将
n_days导出到集群。 - 将
calculate_runs应用于矩阵mat_stocks的每一列。 - 使用
n_days作为period参数的取值。
交互式实操练习
通过完成这段示例代码来试试这个练习。
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)))