com.soteradefense.dga.louvain.giraph

Class LouvainMasterCompute

java.lang.Object

org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable

org.apache.giraph.master.MasterCompute

org.apache.giraph.master.DefaultMasterCompute

com.soteradefense.dga.louvain.giraph.LouvainMasterCompute

All Implemented Interfaces:

AggregatorUsage, ImmutableClassesGiraphConfigurable, MasterAggregatorUsage, Writable

public class LouvainMasterCompute
extends DefaultMasterCompute

Master compute class. performs a compute function before each super step. Performs 4 functions.

1. prints to its standard out the number of nodes that have changed community in each pass 2. prints to its standard out the Q value of the graph when this phase is complete. 3. halts the computation when no further progress is being made (each vertex makes the same decision to halt independently on the previous step, and then aggregate their q values) 4. Determines if this should be the final phase of computation in the pipeline, if so writes a file to indicate such.

Constructor Summary

Constructors

Constructor and Description
LouvainMasterCompute()

Method Summary

Methods

Modifier and Type	Method and Description
void	compute()
protected static boolean	decideToHalt(List<Long> history, Configuration conf) Determine if progress is still being made or if the computation should halt.
void	initialize()

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

readFields, write

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

getAggregatedValue, getComputation, getContext, getMessageCombiner, getSuperstep, getTotalNumEdges, getTotalNumVertices, haltComputation, isHalted, registerAggregator, registerPersistentAggregator, setAggregatedValue, setComputation, setIncomingMessage, setMessageCombiner, setOutgoingMessage

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

LouvainMasterCompute

public LouvainMasterCompute()

Method Detail

initialize

public void initialize()
                throws InstantiationException,
                       IllegalAccessException

Overrides:

initialize in class DefaultMasterCompute

Throws:

InstantiationException

IllegalAccessException

compute

public void compute()

Overrides:

compute in class DefaultMasterCompute

decideToHalt

protected static boolean decideToHalt(List<Long> history,
                   Configuration conf)

Determine if progress is still being made or if the computation should halt.

Parameters:

history -

Returns: