org.apache.giraph.worker

Interface WorkerThreadGlobalCommUsage

All Superinterfaces:

WorkerBroadcastUsage, WorkerGlobalCommUsage, WorkerReduceUsage

All Known Implementing Classes:

WorkerAggregatorHandler, WorkerAggregatorHandler.ThreadLocalWorkerGlobalCommUsage

public interface WorkerThreadGlobalCommUsage
extends WorkerGlobalCommUsage

WorkerAggregatorUsage which can be used in each of the computation threads.

Method Summary

Modifier and Type	Method and Description
void	finishThreadComputation() Call this after thread's computation is finished, i.e.

Methods inherited from interface org.apache.giraph.worker.WorkerBroadcastUsage

getBroadcast

Methods inherited from interface org.apache.giraph.worker.WorkerReduceUsage

reduce, reduceMerge

Method Detail

finishThreadComputation

void finishThreadComputation()

Call this after thread's computation is finished, i.e. when all vertices have provided their values to aggregators