私は Giraph の初心者なので、私の質問には明らかな回答があるかもしれません。
すべての頂点が収束したときに停止し、その後いくつかの計算を行う必要があるアルゴリズムを Giraph に実装しています。
私のアプローチは、収束したらすべての頂点を停止し、残りの作業を続け、すべてが停止したら最終的な計算を行うことでした。しかし、私はそのようにする方法がわかりません。
私の最初のアイデアは正しくないように思われるので、頂点のステータスを格納するフラグを持つアグリゲーターを使用することを考えています。プロセス中に頂点を停止せず、フラグがアクティブになったら最終的な計算を実行して停止します頂点。
これらのうち、ベストプラクティスまたはそれを行う唯一の方法はどれですか? または、他の方法で行う必要がありますか？
ありがとう！