Hi Nicolas,
You are right, using aggregators and master compute is the way to go.
Please take a look at
https://cwiki.apache.org/confluence/display/GIRAPH/Aggregators
to learn more about aggregators. From the MasterCompute.compute() you will
be calling haltComputation() when you decided it's time
Hi,
In my use case (implementation of affinity propagation) I want to halt the
computation if at least of minimum of vertex has voted to halt. As far as I
understand the default is to halt if all vertex has voted to halt and no
messages are sent between vertices. But in my use case, even if a v