Package 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>

All Implemented Interfaces:

org.apache.giraph.aggregators.AggregatorUsage, org.apache.giraph.conf.GiraphConfigurationSettable<I,V,E>, org.apache.giraph.conf.ImmutableClassesGiraphConfigurable<I,V,E>, org.apache.giraph.worker.WorkerAggregatorUsage, org.apache.giraph.worker.WorkerBroadcastUsage, org.apache.giraph.worker.WorkerGlobalCommUsage, org.apache.giraph.worker.WorkerReduceUsage

Direct Known Subclasses:

AbstractComputation, org.apache.giraph.io.EdgeReader, org.apache.giraph.io.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 org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable<I,V,E>
implements org.apache.giraph.worker.WorkerAggregatorUsage, org.apache.giraph.worker.WorkerGlobalCommUsage

Constructor Summary

Constructors

Constructor	Description
WorkerAggregatorDelegator()

Method Summary

Modifier and Type	Method	Description
<A extends org.apache.hadoop.io.Writable> void	aggregate(String name, A value)
<A extends org.apache.hadoop.io.Writable> A	getAggregatedValue(String name)
<B extends org.apache.hadoop.io.Writable> B	getBroadcast(String name)
void	reduce(String name, Object value)
void	reduceMerge(String name, org.apache.hadoop.io.Writable value)
void	setAggregatorManager(AggregatorManager aggregatorManager)

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

setAggregatorManager

public void setAggregatorManager(AggregatorManager aggregatorManager)

reduce

public void reduce(String name,
                   Object value)

Specified by:

reduce in interface org.apache.giraph.worker.WorkerReduceUsage

reduceMerge

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

Specified by:

reduceMerge in interface org.apache.giraph.worker.WorkerReduceUsage

getBroadcast

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

Specified by:

getBroadcast in interface org.apache.giraph.worker.WorkerBroadcastUsage

aggregate

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

Specified by:

aggregate in interface org.apache.giraph.worker.WorkerAggregatorUsage

getAggregatedValue

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

Specified by:

getAggregatedValue in interface org.apache.giraph.aggregators.AggregatorUsage