org.apache.giraph.worker

Class WorkerAggregatorHandler.ThreadLocalWorkerGlobalCommUsage

java.lang.Object

org.apache.giraph.worker.WorkerAggregatorHandler.ThreadLocalWorkerGlobalCommUsage

All Implemented Interfaces:

WorkerBroadcastUsage, WorkerGlobalCommUsage, WorkerReduceUsage, WorkerThreadGlobalCommUsage

Enclosing class:

WorkerAggregatorHandler

public class WorkerAggregatorHandler.ThreadLocalWorkerGlobalCommUsage
extends Object
implements WorkerThreadGlobalCommUsage

Not thread-safe implementation of WorkerThreadGlobalCommUsage. We can use one instance of this object per thread to prevent synchronizing on each aggregate() call. In the end of superstep, values from each of these will be aggregated back to WorkerThreadGlobalCommUsage

Constructor Summary

Constructors

Constructor and Description
ThreadLocalWorkerGlobalCommUsage() Constructor Creates new instances of all reducers from WorkerAggregatorHandler

Method Summary

Modifier and Type	Method and Description
void	finishThreadComputation() Call this after thread's computation is finished, i.e.
<B extends org.apache.hadoop.io.Writable> B	getBroadcast(String name) Get value broadcasted from master
void	reduce(String name, Object value) Reduce given value.
void	reduceMerge(String name, org.apache.hadoop.io.Writable value) Reduce given partial value.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ThreadLocalWorkerGlobalCommUsage

public ThreadLocalWorkerGlobalCommUsage()

Constructor Creates new instances of all reducers from WorkerAggregatorHandler

Method Detail

reduce

public void reduce(String name,
                   Object value)

Description copied from interface: WorkerReduceUsage

Reduce given value.

Specified by:

reduce in interface WorkerReduceUsage

Parameters:

name - Name of the reducer

value - Single value to reduce

reduceMerge

public void reduceMerge(String name,
                        org.apache.hadoop.io.Writable value)

Description copied from interface: WorkerReduceUsage

Reduce given partial value.

Specified by:

reduceMerge in interface WorkerReduceUsage

Parameters:

name - Name of the reducer

value - Single value to reduce

getBroadcast

public <B extends org.apache.hadoop.io.Writable> B getBroadcast(String name)

Description copied from interface: WorkerBroadcastUsage

Get value broadcasted from master

Specified by:

getBroadcast in interface WorkerBroadcastUsage

Type Parameters:

B - Broadcast value type

Parameters:

name - Name of the broadcasted value

Returns:

Broadcasted value

finishThreadComputation

public void finishThreadComputation()

Description copied from interface: WorkerThreadGlobalCommUsage

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

Specified by:

finishThreadComputation in interface WorkerThreadGlobalCommUsage