我是 Giraph 的新手,所以也许我的问题有一个明显的回应。
我正在 Giraph 上实现一个算法,当所有顶点都收敛时需要停止并在之后进行一些计算。
我的方法是在每个顶点收敛后停止它并继续与其余顶点一起工作,一旦所有顶点都停止进行最终计算。但我看不出有办法做到这一点。
由于我的第一个想法似乎不正确,我正在考虑使用具有存储顶点状态的标志的聚合器,在此过程中不停止任何顶点,一旦标志处于活动状态,进行最终计算并停止顶点。
以下哪一项是最佳实践或唯一的方法?还是我应该以其他方式做到这一点?
谢谢!