org.apache.giraph.block_app.migration

Class MigrationMasterCompute

java.lang.Object

org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable

org.apache.giraph.block_app.migration.MigrationMasterCompute

All Implemented Interfaces:

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

Direct Known Subclasses:

MigrationMasterCompute.MigrationFullMasterCompute

public abstract class MigrationMasterCompute
extends DefaultImmutableClassesGiraphConfigurable
implements org.apache.hadoop.io.Writable

Replacement for MasterCompute when migrating to Blocks Framework, disallowing functions that are tied to execution order.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MigrationMasterCompute.MigrationFullMasterCompute Drop-in replacement for MasterCompute when migrating to Blocks Framework.

Constructor Summary

Constructors

Constructor and Description
MigrationMasterCompute()

Method Summary

Modifier and Type	Method and Description
void	broadcast(String name, org.apache.hadoop.io.Writable object)
void	compute()
<A extends org.apache.hadoop.io.Writable> A	getAggregatedValue(String name)
StatusReporter	getContext()
<T extends org.apache.hadoop.io.Writable> T	getReduced(String name)
long	getTotalNumEdges()
long	getTotalNumVertices()
void	initialize()
void	logToCommandLine(String line)
void	readFields(DataInput in)
<A extends org.apache.hadoop.io.Writable> boolean	registerAggregator(String name, Class<? extends Aggregator<A>> aggregatorClass)
<A extends org.apache.hadoop.io.Writable> boolean	registerPersistentAggregator(String name, Class<? extends Aggregator<A>> aggregatorClass)
<S,R extends org.apache.hadoop.io.Writable> void	registerReducer(String name, ReduceOperation<S,R> reduceOp)
<S,R extends org.apache.hadoop.io.Writable> void	registerReducer(String name, ReduceOperation<S,R> reduceOp, R globalInitialValue)
<A extends org.apache.hadoop.io.Writable> void	setAggregatedValue(String name, A value)
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

MigrationMasterCompute

public MigrationMasterCompute()

Method Detail

readFields

public void readFields(DataInput in)
                throws IOException

Specified by:

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

Throws:

IOException

write

public void write(DataOutput out)
           throws IOException

Specified by:

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

Throws:

IOException

compute

public void compute()

initialize

public void initialize()
                throws InstantiationException,
                       IllegalAccessException

Throws:

InstantiationException

IllegalAccessException

getTotalNumVertices

public long getTotalNumVertices()

getTotalNumEdges

public long getTotalNumEdges()

registerReducer

public final <S,R extends org.apache.hadoop.io.Writable> void registerReducer(String name,
                                                                              ReduceOperation<S,R> reduceOp)

registerReducer

public final <S,R extends org.apache.hadoop.io.Writable> void registerReducer(String name,
                                                                              ReduceOperation<S,R> reduceOp,
                                                                              R globalInitialValue)

getReduced

public final <T extends org.apache.hadoop.io.Writable> T getReduced(String name)

broadcast

public final void broadcast(String name,
                            org.apache.hadoop.io.Writable object)

registerAggregator

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

Throws:

InstantiationException

IllegalAccessException

registerPersistentAggregator

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

Throws:

InstantiationException

IllegalAccessException

getAggregatedValue

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

setAggregatedValue

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

logToCommandLine

public final void logToCommandLine(String line)

getContext

public final StatusReporter getContext()