unipg.gila.layout

Class FloodingMaster

java.lang.Object

org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable

org.apache.giraph.master.MasterCompute

org.apache.giraph.master.DefaultMasterCompute

unipg.gila.layout.FloodingMaster

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.hadoop.io.Writable

public class FloodingMaster
extends org.apache.giraph.master.DefaultMasterCompute

This class defines the behaviour of the layout phase of the algorithm, loading the appropriate computations at the right time. It defines the stopping conditions, changes between the seeding and propagating phases and finally reintegrate the one-degree vertices before halting the computation.

Author:

general

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FloodingMaster.DrawingBoundariesExplorer In this computation each vertex simply aggregates its coordinates to the max and min coodinates aggregator of its component.
static class	FloodingMaster.DrawingScaler This computation applies a previously computed transformation stored into an aggregator (scaling+translation) to components' vertices.
static class	FloodingMaster.LayoutCCs Given the scaling and traslating data computed to arrange the connected components, this computation applies them to each vertex.

Field Summary

Fields

Modifier and Type	Field and Description
static float	accuracyDefault
static java.lang.String	accuracyString
protected long	allVertices
static java.lang.String	bbString
protected static java.lang.String	componentNoOfNodes
static java.lang.String	componentPaddingConfString
static java.lang.String	computationLimit
static java.lang.String	coneWidth
static float	coneWidthDefault
static java.lang.String	convergenceAggregatorString
static java.lang.String	convergenceThresholdString
static java.lang.String	coolingSpeed
protected CoolingStrategy	coolingStrategy
static java.lang.String	correctedSizeAGG
protected static java.lang.String	COUNTER_GROUP
static float	defaultConvergenceThreshold
static java.lang.String	defaultCoolingSpeed
static float	defaultInitialTempFactor
static float	defaultNodeValue
static float	defaultPadding
static java.lang.String	dynamicRadiusString
static java.lang.String	forceMethodOptionExtraOptionsString
static java.lang.String	forceMethodOptionString
protected boolean	halting
static java.lang.String	initialTempFactorString
static java.lang.String	k_agg
static float	lowThresholdDefault
static java.lang.String	lowThresholdString
static java.lang.String	maxOneDegAggregatorString
static int	maxSstepsDefault
static java.lang.String	MessagesAggregatorString
static java.lang.String	minimalAngularResolutionString
static java.lang.String	node_length
static java.lang.String	node_separation
static java.lang.String	node_width
protected static java.lang.String	offsetsAggregator
static java.lang.String	oneDegreeReintegratingClassOption
static java.lang.String	paddingString
protected long	propagationSteps
static float	radiusDefault
static java.lang.String	radiusString
static java.lang.String	randomPlacementString
protected int	readyToSleep
protected static java.lang.String	scaleFactorAgg
static java.lang.String	showComponentString
static java.lang.String	showPartitioningString
static java.lang.String	tempAGG
static java.lang.String	tempAggregator
protected float	threshold
static int	ttlMaxDefault
static java.lang.String	ttlMaxString
static float	walshawModifierDefault
static java.lang.String	walshawModifierString

Constructor Summary

Constructors

Constructor and Description
FloodingMaster()

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	checkForConvergence() Check for graph equilibrium.
void	compute() The main master compute method.
protected void	computeComponentGridLayout() This method computes the connected components final grid layout.
void	initialize()
protected void	masterHaltingSequence() The method is used to start the halting sequence and to manage the order of the events leading to the algorithm conclusion.
protected static java.util.LinkedHashMap	sortMapByValues(java.util.Map mapToSort) This method sorts a map by its values.
protected void	superstepOneSpecials() This method executes a number of tasks to tune the algorithm given the proportions of the initial (random) layout of each component.
protected void	updateTemperatureAggregator() Convenience method to update the temperature aggregator each time a new seeding phase is performed.

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, haltComputation, isHalted, logToCommandLine, registerAggregator, registerPersistentAggregator, registerReduce, registerReduce, 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

Field Detail

accuracyDefault

public static final float accuracyDefault

See Also:

Constant Field Values

accuracyString

public static final java.lang.String accuracyString

See Also:

Constant Field Values

allVertices

protected long allVertices

bbString

public static final java.lang.String bbString

See Also:

Constant Field Values

componentNoOfNodes

protected static final java.lang.String componentNoOfNodes

See Also:

Constant Field Values

componentPaddingConfString

public static final java.lang.String componentPaddingConfString

See Also:

Constant Field Values

computationLimit

public static final java.lang.String computationLimit

See Also:

Constant Field Values

coneWidth

public static final java.lang.String coneWidth

See Also:

Constant Field Values

coneWidthDefault

public static final float coneWidthDefault

See Also:

Constant Field Values

convergenceAggregatorString

public static final java.lang.String convergenceAggregatorString

See Also:

Constant Field Values

convergenceThresholdString

public static final java.lang.String convergenceThresholdString

See Also:

Constant Field Values

coolingSpeed

public static final java.lang.String coolingSpeed

See Also:

Constant Field Values

coolingStrategy

protected CoolingStrategy coolingStrategy

correctedSizeAGG

public static final java.lang.String correctedSizeAGG

See Also:

Constant Field Values

COUNTER_GROUP

protected static final java.lang.String COUNTER_GROUP

See Also:

Constant Field Values

defaultConvergenceThreshold

public static final float defaultConvergenceThreshold

See Also:

Constant Field Values

defaultCoolingSpeed

public static final java.lang.String defaultCoolingSpeed

See Also:

Constant Field Values

defaultInitialTempFactor

public static final float defaultInitialTempFactor

See Also:

Constant Field Values

defaultNodeValue

public static final float defaultNodeValue

See Also:

Constant Field Values

defaultPadding

public static final float defaultPadding

See Also:

Constant Field Values

dynamicRadiusString

public static final java.lang.String dynamicRadiusString

See Also:

Constant Field Values

forceMethodOptionExtraOptionsString

public static final java.lang.String forceMethodOptionExtraOptionsString

See Also:

Constant Field Values

forceMethodOptionString

public static final java.lang.String forceMethodOptionString

See Also:

Constant Field Values

halting

protected boolean halting

initialTempFactorString

public static final java.lang.String initialTempFactorString

See Also:

Constant Field Values

k_agg

public static final java.lang.String k_agg

See Also:

Constant Field Values

lowThresholdDefault

public static final float lowThresholdDefault

See Also:

Constant Field Values

lowThresholdString

public static final java.lang.String lowThresholdString

See Also:

Constant Field Values

maxOneDegAggregatorString

public static final java.lang.String maxOneDegAggregatorString

See Also:

Constant Field Values

maxSstepsDefault

public static final int maxSstepsDefault

See Also:

Constant Field Values

MessagesAggregatorString

public static final java.lang.String MessagesAggregatorString

See Also:

Constant Field Values

minimalAngularResolutionString

public static final java.lang.String minimalAngularResolutionString

See Also:

Constant Field Values

node_length

public static final java.lang.String node_length

See Also:

Constant Field Values

node_separation

public static final java.lang.String node_separation

See Also:

Constant Field Values

node_width

public static final java.lang.String node_width

See Also:

Constant Field Values

offsetsAggregator

protected static final java.lang.String offsetsAggregator

See Also:

Constant Field Values

oneDegreeReintegratingClassOption

public static final java.lang.String oneDegreeReintegratingClassOption

See Also:

Constant Field Values

paddingString

public static final java.lang.String paddingString

See Also:

Constant Field Values

propagationSteps

protected long propagationSteps

radiusDefault

public static final float radiusDefault

See Also:

Constant Field Values

radiusString

public static final java.lang.String radiusString

See Also:

Constant Field Values

randomPlacementString

public static final java.lang.String randomPlacementString

See Also:

Constant Field Values

readyToSleep

protected int readyToSleep

scaleFactorAgg

protected static final java.lang.String scaleFactorAgg

See Also:

Constant Field Values

showComponentString

public static final java.lang.String showComponentString

See Also:

Constant Field Values

showPartitioningString

public static final java.lang.String showPartitioningString

See Also:

Constant Field Values

tempAGG

public static final java.lang.String tempAGG

See Also:

Constant Field Values

tempAggregator

public static final java.lang.String tempAggregator

See Also:

Constant Field Values

threshold

protected float threshold

ttlMaxDefault

public static final int ttlMaxDefault

See Also:

Constant Field Values

ttlMaxString

public static final java.lang.String ttlMaxString

See Also:

Constant Field Values

walshawModifierDefault

public static final float walshawModifierDefault

See Also:

Constant Field Values

walshawModifierString

public static final java.lang.String walshawModifierString

See Also:

Constant Field Values

Constructor Detail

FloodingMaster

public FloodingMaster()

Method Detail

checkForConvergence

protected boolean checkForConvergence()

Check for graph equilibrium.

Returns:

true if the number of vertices which did not move above the threshold is higher than the convergence threshold.

compute

public void compute()

The main master compute method.

Overrides:

compute in class org.apache.giraph.master.DefaultMasterCompute

computeComponentGridLayout

protected void computeComponentGridLayout()

This method computes the connected components final grid layout.

initialize

public void initialize()
                throws java.lang.InstantiationException,
                       java.lang.IllegalAccessException

Overrides:

initialize in class org.apache.giraph.master.DefaultMasterCompute

Throws:

java.lang.InstantiationException

java.lang.IllegalAccessException

masterHaltingSequence

protected void masterHaltingSequence()

The method is used to start the halting sequence and to manage the order of the events leading to the algorithm conclusion.

Throws:

java.lang.IllegalAccessException

sortMapByValues

protected static java.util.LinkedHashMap sortMapByValues(java.util.Map mapToSort)

This method sorts a map by its values.

Parameters:

mapToSort -

Returns:

The sorted LinkedHashMap.

superstepOneSpecials

protected void superstepOneSpecials()
                             throws java.lang.IllegalAccessException

This method executes a number of tasks to tune the algorithm given the proportions of the initial (random) layout of each component.

Throws:

java.lang.IllegalAccessException

updateTemperatureAggregator

protected void updateTemperatureAggregator()

Convenience method to update the temperature aggregator each time a new seeding phase is performed.