org.apache.hadoop.tools.rumen

类 AbstractClusterStory

java.lang.Object

org.apache.hadoop.tools.rumen.AbstractClusterStory

所有已实现的接口:

ClusterStory

直接已知子类:

ZombieCluster

public abstract class AbstractClusterStory
extends Object
implements ClusterStory

AbstractClusterStory provides a partial implementation of ClusterStory by parsing the topology tree.

字段概要

字段

限定符和类型	字段和说明
protected Set<MachineNode>	machineNodes
protected int	maximumDistance
protected Map<String,MachineNode>	mNodeMap
protected MachineNode[]	mNodesFlattened
protected Set<RackNode>	rackNodes
protected Map<String,RackNode>	rNodeMap

构造器概要

构造器

构造器和说明
AbstractClusterStory()

方法概要

方法

限定符和类型	方法和说明
protected void	buildMachineNodeMap()
protected void	buildRackNodeMap()
int	distance(Node a, Node b) Determine the distance between two Nodes.
MachineNode	getMachineByName(String name) Get MachineNode by its host name.
Set<MachineNode>	getMachines() Get all machines of the cluster.
int	getMaximumDistance() Get the maximum distance possible between any two nodes.
RackNode	getRackByName(String name) Get RackNode by its name.
Set<RackNode>	getRacks() Get all racks of the cluster.
MachineNode[]	getRandomMachines(int expected, Random random) Select a random set of machines.
protected void	parseTopologyTree()

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 org.apache.hadoop.tools.rumen.ClusterStory

getClusterTopology

字段详细资料

machineNodes

protected Set<MachineNode> machineNodes

rackNodes

protected Set<RackNode> rackNodes

mNodesFlattened

protected MachineNode[] mNodesFlattened

mNodeMap

protected Map<String,MachineNode> mNodeMap

rNodeMap

protected Map<String,RackNode> rNodeMap

maximumDistance

protected int maximumDistance

构造器详细资料

AbstractClusterStory

public AbstractClusterStory()

方法详细资料

getMachines

public Set<MachineNode> getMachines()

从接口复制的说明: ClusterStory

Get all machines of the cluster.

指定者:

getMachines 在接口中 ClusterStory

返回:

A read-only set that contains all machines of the cluster.

getRacks

public Set<RackNode> getRacks()

从接口复制的说明: ClusterStory

Get all racks of the cluster.

指定者:

getRacks 在接口中 ClusterStory

返回:

A read-only set that contains all racks of the cluster.

getRandomMachines

public MachineNode[] getRandomMachines(int expected,
                              Random random)

从接口复制的说明: ClusterStory

Select a random set of machines.

指定者:

getRandomMachines 在接口中 ClusterStory

参数:

expected - The expected sample size.

random - Random number generator to use.

返回:

An array of up to expected number of MachineNodes.

buildMachineNodeMap

protected void buildMachineNodeMap()

getMachineByName

public MachineNode getMachineByName(String name)

从接口复制的说明: ClusterStory

Get MachineNode by its host name.

指定者:

getMachineByName 在接口中 ClusterStory

返回:

The MachineNode with the same name. Or null if not found.

distance

public int distance(Node a,
           Node b)

从接口复制的说明: ClusterStory

Determine the distance between two Nodes. Currently, the distance is loosely defined as the length of the longer path for either a or b to reach their common ancestor.

指定者:

distance 在接口中 ClusterStory

返回:

The distance between Node a and Node b.

buildRackNodeMap

protected void buildRackNodeMap()

getRackByName

public RackNode getRackByName(String name)

从接口复制的说明: ClusterStory

Get RackNode by its name.

指定者:

getRackByName 在接口中 ClusterStory

返回:

The RackNode with the same name. Or null if not found.

getMaximumDistance

public int getMaximumDistance()

从接口复制的说明: ClusterStory

Get the maximum distance possible between any two nodes.

指定者:

getMaximumDistance 在接口中 ClusterStory

返回:

the maximum distance possible between any two nodes.

parseTopologyTree

protected void parseTopologyTree()