@InterfaceAudience.Private @InterfaceStability.Evolving public class DatanodeID extends Object implements Comparable<DatanodeID>
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.Modifier and Type | Field and Description |
---|---|
static DatanodeID[] |
EMPTY_ARRAY |
Constructor and Description |
---|
DatanodeID(DatanodeID from) |
DatanodeID(String ipAddr,
String hostName,
String storageID,
int xferPort,
int infoPort,
int infoSecurePort,
int ipcPort)
Create a DatanodeID
|
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.
|
public static final DatanodeID[] EMPTY_ARRAY
public DatanodeID(DatanodeID from)
public DatanodeID(String ipAddr, String hostName, String storageID, int xferPort, int infoPort, int infoSecurePort, int ipcPort)
ipAddr
- IPhostName
- hostnamestorageID
- data storage IDxferPort
- data transfer portinfoPort
- info server portipcPort
- ipc server portpublic void setIpAddr(String ipAddr)
public void setPeerHostName(String peerHostName)
public void setStorageID(String storageID)
public String getIpAddr()
public String getHostName()
public String getPeerHostName()
public String getXferAddr()
public String getInfoAddr()
public String getInfoSecureAddr()
public String getXferAddrWithHostname()
public String getXferAddr(boolean useHostname)
useHostname
- true to use the DN hostname, use the IP otherwisepublic String getIpcAddr(boolean useHostname)
useHostname
- true to use the DN hostname, use the IP otherwisepublic String getStorageID()
public int getXferPort()
public int getInfoPort()
public int getInfoSecurePort()
public int getIpcPort()
public void updateRegInfo(DatanodeID nodeReg)
public int compareTo(DatanodeID that)
compareTo
in interface Comparable<DatanodeID>
that
- datanode to compare withCopyright © 2013 Apache Software Foundation. All rights reserved.