org.apache.giraph.master

Class DefaultMasterCompute

java.lang.Object

org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable

org.apache.giraph.master.MasterCompute

org.apache.giraph.master.DefaultMasterCompute

All Implemented Interfaces:

AggregatorUsage, GiraphConfigurationSettable, ImmutableClassesGiraphConfigurable, MasterAggregatorUsage, MasterGlobalCommUsage, MasterGlobalCommUsageAggregators, org.apache.hadoop.io.Writable

Direct Known Subclasses:

AggregatorsBenchmark.AggregatorsBenchmarkMasterCompute, AggregatorsTestComputation.AggregatorsTestMasterCompute, PageRankWithKryoSimpleWritable.PageRankWithKryoMasterCompute, RandomMessageBenchmark.RandomMessageBenchmarkMasterCompute, RandomWalkVertexMasterCompute, ReducersBenchmark.ReducersBenchmarkMasterCompute, SccPhaseMasterCompute, SimpleCheckpoint.SimpleCheckpointVertexMasterCompute, SimpleMasterComputeComputation.SimpleMasterCompute, SimplePageRankComputation.SimplePageRankMasterCompute, VerifyMessage.VerifyMessageMasterCompute

public class DefaultMasterCompute
extends MasterCompute

A dumb implementation of MasterCompute. This is the default implementation when no MasterCompute is defined by the user. It does nothing.

Constructor Summary

Constructors

Constructor and Description
DefaultMasterCompute()

Method Summary

Modifier and Type	Method and Description
void	compute() Must be defined by user to specify what the master has to do.
void	initialize() Initialize the MasterCompute class, this is the place to register aggregators.
void	readFields(DataInput in)
void	write(DataOutput out)

Methods inherited from class org.apache.giraph.master.MasterCompute

broadcast, getAggregatedValue, getComputation, getContext, getMessageCombiner, getReduced, getSuperstep, getTotalNumEdges, getTotalNumVertices, getWorkerInfoList, haltComputation, isHalted, logToCommandLine, registerAggregator, registerPersistentAggregator, registerReducer, registerReducer, setAggregatedValue, setComputation, setGraphState, setIncomingMessage, setMasterService, setMessageCombiner, setOutgoingMessage, setOutgoingMessageClasses, setSuperstepClasses

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

DefaultMasterCompute

public DefaultMasterCompute()

Method Detail

readFields

public void readFields(DataInput in)
                throws IOException

Throws:

IOException

write

public void write(DataOutput out)
           throws IOException

Throws:

IOException

compute

public void compute()

Description copied from class: MasterCompute

Must be defined by user to specify what the master has to do.

Specified by:

compute in class MasterCompute

initialize

public void initialize()
                throws InstantiationException,
                       IllegalAccessException

Description copied from class: MasterCompute

Initialize the MasterCompute class, this is the place to register aggregators.

Specified by:

initialize in class MasterCompute

Throws:

InstantiationException

IllegalAccessException