I'm working on an algorithm that computes a global value of the graph
(its so called effective diameter) and I have an Aggregator with which
this value can be computed. What would be the correct place to implement
this computation?

I thought about WorkerContext first, but it seems that this is run on
each worker, which doesn't really fit my problem. Another question would
be how to persist that global value after the algorithm is done.


Reply via email to