Apache Giraph:每个分区处理的顶点数
Apache Giraph : Number of vertices processed by each partition
我是一个新手,正在尝试了解 Giraph 1.2.0 的工作原理。使用 hadoop 1.2.1.
有什么方法可以计算出每个映射器处理的顶点数吗?
org.apache.giraph.graph.ComputeCallableclass的调用方法每超步执行一次。在这个函数内部,对于这个映射任务拥有的每个分区,调用 computePartition 函数。因此,您可以轻松地为此 class 定义一个整数(计数器)。然后,在 computePartition 中,如果调用了顶点的 compute 方法,则增加计数器。最后,在调用方法结束时打印您的计数器。因此,对于每个映射器的每个超步,它都会打印处理的顶点数。
我是一个新手,正在尝试了解 Giraph 1.2.0 的工作原理。使用 hadoop 1.2.1.
有什么方法可以计算出每个映射器处理的顶点数吗?
org.apache.giraph.graph.ComputeCallableclass的调用方法每超步执行一次。在这个函数内部,对于这个映射任务拥有的每个分区,调用 computePartition 函数。因此,您可以轻松地为此 class 定义一个整数(计数器)。然后,在 computePartition 中,如果调用了顶点的 compute 方法,则增加计数器。最后,在调用方法结束时打印您的计数器。因此,对于每个映射器的每个超步,它都会打印处理的顶点数。