1

我正在使用 Giraph 运行一些基本示例，并且我想验证我的EdgeInputFormat. 在经典的 MapReduce 工作中，我可以使用 Counters 来做到这一点，而 Giraph 为此使用聚合器。（https://giraph.apache.org/aggregators.html）

网站上说聚合器应该在master上注册。我编写的唯一代码是一个扩展BasicComputation并实现了 compute() 方法的类。有人可以指出我应该在哪里注册它们以及在读取数据时如何使用它们？

4

1 回答 1

1

我已经想出办法了。

我已经实现了一个扩展类，MasterCompute并在 initialize() 方法中注册了一个持久聚合器。我用过IntSumAggregator。

在那之后，EdgeInputFormat我可以使用aggregate("myAggregator", new IntWritable(1));.

使用line 参数MasterCompute设置。-mc

于 2014-06-12T14:33:47.443 回答