ruby - 流作业中有多个mapper和reducer文件

我在Ruby中构建了一个映射器和一个reducer，它作为流作业成功运行。但是，我需要做第二张 map ，并根据最后一个reduce的输出进行reduce。

有什么方法可以在流作业中为映射器和化简器定义多个Ruby文件？喜欢链接。

最佳答案

没有。

但是，您可以链接两个流作业，并且仅将第一个的输出目录用作第二个的输入目录。