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