Apache Giraph：每个分区处理的顶点数

Question

我是一个新手，试图了解 Giraph 1.2.0 的工作原理。使用 hadoop 1.2.1。

有什么办法可以算出每个mapper处理的顶点数？

Answer 1

org.apache.giraph.graph.ComputeCallable 类的调用方法在每个 superstep 中执行一次。在这个函数内部，对于这个 map 任务拥有的每个分区，都会调用 computePartition 函数。因此，您可以轻松地为此类定义一个整数（计数器）。然后，在 computePartition 中，如果调用了顶点的计算方法，则递增计数器。最后，在调用方法结束时打印您的计数器。因此，对于每个映射器的每个超步，它都会打印处理的顶点数。