org.apache.hadoop.hdfs.protocol

Class DatanodeID

java.lang.Object

org.apache.hadoop.hdfs.protocol.DatanodeID

All Implemented Interfaces:

Comparable<DatanodeID>

Direct Known Subclasses:

DatanodeInfo, DatanodeRegistration

@InterfaceAudience.Private
@InterfaceStability.Evolving
public class DatanodeID
extends Object
implements Comparable<DatanodeID>

This class represents the primary identifier for a Datanode. Datanodes are identified by how they can be contacted (hostname and ports) and their storage ID, a unique number that associates the Datanodes blocks with a particular Datanode. DatanodeInfo.getName() should be used to get the network location (for topology) of a datanode, instead of using getXferAddr() here. Helpers are defined below for each context in which a DatanodeID is used.

Field Summary

Fields

Modifier and Type	Field and Description
static DatanodeID[]	EMPTY_ARRAY

Constructor Summary

Constructors

Constructor and Description
DatanodeID(DatanodeID from)
DatanodeID(String ipAddr, String hostName, String storageID, int xferPort, int infoPort, int infoSecurePort, int ipcPort) Create a DatanodeID

Method Summary

Methods

Modifier and Type	Method and Description
int	compareTo(DatanodeID that) Compare based on data transfer address.
boolean	equals(Object to)
String	getHostName()
String	getInfoAddr()
int	getInfoPort()
String	getInfoSecureAddr()
int	getInfoSecurePort()
String	getIpAddr()
String	getIpcAddr(boolean useHostname)
int	getIpcPort()
String	getPeerHostName()
String	getStorageID()
String	getXferAddr()
String	getXferAddr(boolean useHostname)
String	getXferAddrWithHostname()
int	getXferPort()
int	hashCode()
void	setIpAddr(String ipAddr)
void	setPeerHostName(String peerHostName)
void	setStorageID(String storageID)
String	toString()
void	updateRegInfo(DatanodeID nodeReg) Update fields when a new registration request comes in.

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

EMPTY_ARRAY

public static final DatanodeID[] EMPTY_ARRAY

Constructor Detail

DatanodeID

public DatanodeID(DatanodeID from)

DatanodeID

public DatanodeID(String ipAddr,
          String hostName,
          String storageID,
          int xferPort,
          int infoPort,
          int infoSecurePort,
          int ipcPort)

Create a DatanodeID

Parameters:

ipAddr - IP

hostName - hostname

storageID - data storage ID

xferPort - data transfer port

infoPort - info server port

ipcPort - ipc server port

Method Detail

setIpAddr

public void setIpAddr(String ipAddr)

setPeerHostName

public void setPeerHostName(String peerHostName)

setStorageID

public void setStorageID(String storageID)

getIpAddr

public String getIpAddr()

Returns:

ipAddr;

getHostName

public String getHostName()

Returns:

hostname

getPeerHostName

public String getPeerHostName()

Returns:

hostname from the actual connection

getXferAddr

public String getXferAddr()

Returns:

IP:xferPort string

getInfoAddr

public String getInfoAddr()

Returns:

IP:infoPort string

getInfoSecureAddr

public String getInfoSecureAddr()

Returns:

IP:infoPort string

getXferAddrWithHostname

public String getXferAddrWithHostname()

Returns:

hostname:xferPort

getXferAddr

public String getXferAddr(boolean useHostname)

Parameters:

useHostname - true to use the DN hostname, use the IP otherwise

Returns:

name:xferPort

getIpcAddr

public String getIpcAddr(boolean useHostname)

Parameters:

useHostname - true to use the DN hostname, use the IP otherwise

Returns:

name:ipcPort

getStorageID

public String getStorageID()

Returns:

data storage ID.

getXferPort

public int getXferPort()

Returns:

xferPort (the port for data streaming)

getInfoPort

public int getInfoPort()

Returns:

infoPort (the port at which the HTTP server bound to)

getInfoSecurePort

public int getInfoSecurePort()

Returns:

infoSecurePort (the port at which the HTTPS server bound to)

getIpcPort

public int getIpcPort()

Returns:

ipcPort (the port at which the IPC server bound to)

equals

public boolean equals(Object to)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

updateRegInfo

public void updateRegInfo(DatanodeID nodeReg)

Update fields when a new registration request comes in. Note that this does not update storageID.

compareTo

public int compareTo(DatanodeID that)

Compare based on data transfer address.

Specified by:

compareTo in interface Comparable<DatanodeID>

Parameters:

that - datanode to compare with

Returns:

as specified by Comparable