org.apache.giraph.worker

Class WorkerAggregatorDelegator<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

java.lang.Object

org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable<I,V,E>

org.apache.giraph.worker.WorkerAggregatorDelegator<I,V,E>

Type Parameters:

I - Vertex id

V - Vertex data

E - Edge data

All Implemented Interfaces:

AggregatorUsage, GiraphConfigurationSettable<I,V,E>, ImmutableClassesGiraphConfigurable<I,V,E>, WorkerAggregatorUsage, WorkerBroadcastUsage, WorkerGlobalCommUsage, WorkerReduceUsage

Direct Known Subclasses:

AbstractComputation, EdgeReader, MappingReader, MigrationAbstractComputation, VertexReader, WorkerContext

public abstract class WorkerAggregatorDelegator<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
extends DefaultImmutableClassesGiraphConfigurable<I,V,E>
implements WorkerAggregatorUsage, WorkerGlobalCommUsage

Class for delegating WorkerAggregatorUsage and WorkerGlobalCommUsage methods to corresponding interface.

Constructor Summary

Constructors

Constructor and Description
WorkerAggregatorDelegator()

Method Summary

Modifier and Type	Method and Description
<A extends org.apache.hadoop.io.Writable> void	aggregate(String name, A value) Add a new value
<A extends org.apache.hadoop.io.Writable> A	getAggregatedValue(String name) Get value of an aggregator.
<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.
void	setWorkerGlobalCommUsage(WorkerGlobalCommUsage workerGlobalCommUsage) Set worker global communication usage

Methods inherited from class org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable

getConf, setConf

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkerAggregatorDelegator

public WorkerAggregatorDelegator()

Method Detail

setWorkerGlobalCommUsage

public void setWorkerGlobalCommUsage(WorkerGlobalCommUsage workerGlobalCommUsage)

Set worker global communication usage

Parameters:

workerGlobalCommUsage - Worker global communication usage

reduce

public final 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 final <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

aggregate

public final <A extends org.apache.hadoop.io.Writable> void aggregate(String name,
                                                                      A value)

Description copied from interface: WorkerAggregatorUsage

Add a new value

Specified by:

aggregate in interface WorkerAggregatorUsage

Type Parameters:

A - Aggregated value

Parameters:

name - Name of aggregator

value - Value to add

getAggregatedValue

public <A extends org.apache.hadoop.io.Writable> A getAggregatedValue(String name)

Description copied from interface: AggregatorUsage

Get value of an aggregator.

Specified by:

getAggregatedValue in interface AggregatorUsage

Type Parameters:

A - Aggregated value

Parameters:

name - Name of aggregator

Returns:

Value of the aggregator