org.apache.giraph.master

Class AggregatorToGlobalCommTranslation

java.lang.Object

org.apache.giraph.master.AggregatorToGlobalCommTranslation

All Implemented Interfaces:

AggregatorUsage, MasterAggregatorUsage, org.apache.hadoop.io.Writable

public class AggregatorToGlobalCommTranslation
extends Object
implements MasterAggregatorUsage, org.apache.hadoop.io.Writable

Class that translates aggregator handling on the master to reduce and broadcast operations supported by the MasterAggregatorHandler.

Constructor Summary

Constructors

Constructor and Description
AggregatorToGlobalCommTranslation(ImmutableClassesGiraphConfiguration<?,?,?> conf, MasterGlobalCommUsage globalComm) Constructor

Method Summary

Modifier and Type	Method and Description
<A extends org.apache.hadoop.io.Writable> A	getAggregatedValue(String name) Get value of an aggregator.
void	postMasterCompute() Called after master compute, to do aggregator->reduce/broadcast translation
void	prepareSuperstep() Prepare before calling master compute
void	readFields(DataInput in)
<A extends org.apache.hadoop.io.Writable> boolean	registerAggregator(String name, Class<? extends Aggregator<A>> aggregatorClass) Register an aggregator in preSuperstep() and/or preApplication().
<A extends org.apache.hadoop.io.Writable> boolean	registerPersistentAggregator(String name, Class<? extends Aggregator<A>> aggregatorClass) Register persistent aggregator in preSuperstep() and/or preApplication().
<A extends org.apache.hadoop.io.Writable> void	setAggregatedValue(String name, A value) Sets value of an aggregator.
void	write(DataOutput out)

Methods inherited from class java.lang.Object

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

Constructor Detail

AggregatorToGlobalCommTranslation

public AggregatorToGlobalCommTranslation(ImmutableClassesGiraphConfiguration<?,?,?> conf,
                                         MasterGlobalCommUsage globalComm)

Constructor

Parameters:

conf - Configuration

globalComm - Global communication interface

Method Detail

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

setAggregatedValue

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

Description copied from interface: MasterAggregatorUsage

Sets value of an aggregator.

Specified by:

setAggregatedValue in interface MasterAggregatorUsage

Type Parameters:

A - Aggregated value

Parameters:

name - Name of aggregator

value - Value to set

postMasterCompute

public void postMasterCompute()

Called after master compute, to do aggregator->reduce/broadcast translation

prepareSuperstep

public void prepareSuperstep()

Prepare before calling master compute

registerAggregator

public <A extends org.apache.hadoop.io.Writable> boolean registerAggregator(String name,
                                                                            Class<? extends Aggregator<A>> aggregatorClass)
                                                                     throws InstantiationException,
                                                                            IllegalAccessException

Description copied from interface: MasterAggregatorUsage

Register an aggregator in preSuperstep() and/or preApplication(). This aggregator will have its value reset at the end of each super step.

Specified by:

registerAggregator in interface MasterAggregatorUsage

Type Parameters:

A - Aggregator type

Parameters:

name - of aggregator

aggregatorClass - Class type of the aggregator

Returns:

True iff aggregator wasn't already registered

Throws:

InstantiationException

IllegalAccessException

registerPersistentAggregator

public <A extends org.apache.hadoop.io.Writable> boolean registerPersistentAggregator(String name,
                                                                                      Class<? extends Aggregator<A>> aggregatorClass)
                                                                               throws InstantiationException,
                                                                                      IllegalAccessException

Description copied from interface: MasterAggregatorUsage

Register persistent aggregator in preSuperstep() and/or preApplication(). This aggregator will not reset value at the end of super step.

Specified by:

registerPersistentAggregator in interface MasterAggregatorUsage

Type Parameters:

A - Aggregator type

Parameters:

name - of aggregator

aggregatorClass - Class type of the aggregator

Returns:

True iff aggregator wasn't already registered

Throws:

InstantiationException

IllegalAccessException

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