我有一个映射器管道,其中映射函数使用
增加计数器yield op.counters.Increment("mycounter")
但是我不知道如何在管道完成后访问"mycounter"的值。我见过使用完成处理程序的示例,但它们似乎引用了一个较旧的mapreduce库,其中可以实际定义一个完成处理程序。
我最好的猜测是,我需要在管道中定义一个最后阶段,该阶段可以访问映射器管道的计数器——但具体如何定义呢?
正如在这个相关问题中所回答的那样,这个特性现在还不可用。在他们的问题跟踪器(issue 208)中有一个功能请求,目前状态为"已启动"。