org.apache.giraph.master

Class AggregatorBroadcast<A extends org.apache.hadoop.io.Writable>

java.lang.Object

org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable

org.apache.giraph.master.AggregatorBroadcast<A>

Type Parameters:

A - Aggregation object type

All Implemented Interfaces:

GiraphConfigurationSettable, ImmutableClassesGiraphConfigurable, org.apache.hadoop.io.Writable

public class AggregatorBroadcast<A extends org.apache.hadoop.io.Writable>
extends DefaultImmutableClassesGiraphConfigurable
implements org.apache.hadoop.io.Writable

Writable representation of aggregated value

Constructor Summary

Constructors

Constructor and Description
AggregatorBroadcast() Constructor
AggregatorBroadcast(Class<? extends Aggregator<A>> aggregatorClass, A value) Constructor

Method Summary

Modifier and Type	Method and Description
A	getValue()
void	readFields(DataInput in)
void	write(DataOutput out)

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

AggregatorBroadcast

public AggregatorBroadcast()

Constructor

AggregatorBroadcast

public AggregatorBroadcast(Class<? extends Aggregator<A>> aggregatorClass,
                           A value)

Constructor

Parameters:

aggregatorClass - Aggregator class

value - Aggregated value

Method Detail

getValue

public A getValue()

write

public void write(DataOutput out)
           throws IOException

Specified by:

write in interface org.apache.hadoop.io.Writable

Throws:

IOException

readFields

public void readFields(DataInput in)
                throws IOException

Specified by:

readFields in interface org.apache.hadoop.io.Writable

Throws:

IOException