2

http://code.google.com/p/appengine-mapreduce/提到它可以控制执行速度，但我不知道如何。为映射器作业创建任务队列并从那里控制速度是有意义的，但我不知道如何指定要使用的队列。

4

3 回答 3

2

我自己不使用 Java 版本，但 Python 版本有一个processing_rate您传递给映射器规范的参数。

在 Java 源代码中快速搜索会发现一个MAPPER_INPUT_PROCESSING_RATE_KEY配置键，它有望为您指明正确的方向。

于 2011-05-16T20:45:07.063 回答
2

（感谢 Chris 提供的指针，但之后需要进行一些挖掘才能找到确切的参数。）

从http://code.google.com/p/appengine-mapreduce/wiki/UserGuideJava将其添加到您的 mapreduce.xml 配置元素以限制每秒处理的实体数量：

<property>
    <name>mapreduce.mapper.inputprocessingrate</name>
    <value>4</value>
</property>
于 2012-02-01T08:43:29.070 回答
1

对于使用 python 的用户，您可能希望在 model.py 中搜索这个名为“_DEFAULT_PROCESSING_RATE_PER_SEC”的变量，以提高每秒的默认处理速率。这对我有用！

于 2012-02-11T08:50:50.007 回答