org.apache.giraph.benchmark

Class AggregatorsBenchmark.AggregatorsBenchmarkMasterCompute

java.lang.Object

org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable

org.apache.giraph.master.MasterCompute

org.apache.giraph.master.DefaultMasterCompute

org.apache.giraph.benchmark.AggregatorsBenchmark.AggregatorsBenchmarkMasterCompute

All Implemented Interfaces:

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

Enclosing class:

AggregatorsBenchmark

public static class AggregatorsBenchmark.AggregatorsBenchmarkMasterCompute
extends DefaultMasterCompute

MasterCompute class for AggregatorsBenchmark

Constructor Summary

Constructors

Constructor and Description
AggregatorsBenchmarkMasterCompute()

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.

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

readFields, write

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

AggregatorsBenchmarkMasterCompute

public AggregatorsBenchmarkMasterCompute()

Method Detail

initialize

public void initialize()
                throws InstantiationException,
                       IllegalAccessException

Description copied from class: MasterCompute

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

Overrides:

initialize in class DefaultMasterCompute

Throws:

InstantiationException

IllegalAccessException

compute

public void compute()

Description copied from class: MasterCompute

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

Overrides:

compute in class DefaultMasterCompute