Package com.alibaba.graphscope.example.giraph

Class AggregateBenchmark.AggregateBenchmarkMasterCompute

java.lang.Object

org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable

org.apache.giraph.master.MasterCompute

org.apache.giraph.master.DefaultMasterCompute

com.alibaba.graphscope.example.giraph.AggregateBenchmark.AggregateBenchmarkMasterCompute

All Implemented Interfaces:

org.apache.giraph.aggregators.AggregatorUsage, org.apache.giraph.conf.GiraphConfigurationSettable, org.apache.giraph.conf.ImmutableClassesGiraphConfigurable, org.apache.giraph.master.MasterAggregatorUsage, org.apache.giraph.master.MasterGlobalCommUsage, org.apache.giraph.master.MasterGlobalCommUsageAggregators, org.apache.hadoop.io.Writable

Enclosing class:

AggregateBenchmark

public static class AggregateBenchmark.AggregateBenchmarkMasterCompute
extends org.apache.giraph.master.DefaultMasterCompute

Master compute associated with PageRank. It registers required aggregators.

Constructor Summary

Constructors

Constructor	Description
AggregateBenchmarkMasterCompute()

Method Summary

Modifier and Type	Method	Description
void	initialize()	Initialize the MasterCompute class, this is the place to register aggregators.

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

compute, readFields, write

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

broadcast, getAggregatedValue, getComputation, getContext, getMessageCombiner, getReduced, getSuperstep, getTotalNumEdges, getTotalNumVertices, haltComputation, incSuperStep, isHalted, logToCommandLine, registerAggregator, registerPersistentAggregator, registerReducer, registerReducer, setAggregatedValue, setAggregatorManager, setComputation, setFragment, setIncomingMessage, setMessageCombiner, setOutgoingMessage, setOutgoingMessageClasses, setSuperStep

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

AggregateBenchmarkMasterCompute

public AggregateBenchmarkMasterCompute()

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 org.apache.giraph.master.DefaultMasterCompute

Throws:

InstantiationException

IllegalAccessException