我在ruby中构建了一个Map器和一个reducer，它作为一个流作业成功运行。然而，我需要做第二个map和reduce基于最后reduce的输出。
有没有什么方法可以在我的流媒体工作中为Map器和还原器定义多个ruby文件？就像锁链一样。