การดำเนินการกับคอลัมน์โดยใช้ข้อมูลปริมาณการซื้อขาย

ปริมาณการซื้อขาย (volume) คือจำนวนหุ้นที่มีการซื้อหรือขายในช่วงเวลาหนึ่ง สมมติว่าคุณทำงานเป็น Business Analyst ในบริษัทนายหน้าซื้อขายหุ้น โดยมีเมทริกซ์ mat_stocks ที่เก็บข้อมูลการเปลี่ยนแปลงรายวันของปริมาณการซื้อขาย แต่ละคอลัมน์แสดงการเปลี่ยนแปลงของปริมาณการซื้อขายของหุ้นแต่ละตัวเทียบกับวันก่อนหน้า คุณต้องการตรวจสอบว่าปริมาณการซื้อขายของหุ้นเหล่านี้เพิ่มขึ้นอย่างต่อเนื่องในช่วงเวลาที่กำหนดหรือไม่

ฟังก์ชัน calculate_runs() พร้อมใช้งานแล้ว โดยรับอาร์กิวเมนต์ 2 ตัว ได้แก่ 1) การเปลี่ยนแปลงรายวันของปริมาณการซื้อขาย และ 2) ระยะเวลา (จำนวนวัน) ที่ต้องการคำนวณ run

ให้นำ calculate_runs() ไปใช้กับทุกคอลัมน์ของ mat_stocks แบบขนาน โดยกำหนดระยะเวลาเป็น 5 วัน แพ็กเกจ parallel ถูกโหลดไว้ให้แล้ว

แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร

การเขียนโปรแกรมแบบขนานใน R

ดูคอร์ส

คำแนะนำการฝึกหัด

Export n_days ไปยัง cluster
นำ calculate_runs ไปใช้กับแต่ละคอลัมน์ของเมทริกซ์ mat_stocks
ระบุค่าสำหรับอาร์กิวเมนต์ period ด้วย n_days

แบบฝึกหัดเชิงโต้ตอบแบบลงมือทำ

ลองทำแบบฝึกหัดนี้โดยเติมโค้ดตัวอย่างนี้ให้สมบูรณ์

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

แก้ไขและรันโค้ด