@InterfaceAudience.Private @InterfaceStability.Unstable public class RMNodeWrapper extends Object implements org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNode
Constructor and Description |
---|
RMNodeWrapper(org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNode node) |
Modifier and Type | Method and Description |
---|---|
List<org.apache.hadoop.yarn.api.records.ApplicationId> |
getAppsToCleanup() |
int |
getCommandPort() |
List<org.apache.hadoop.yarn.api.records.ContainerId> |
getContainersToCleanUp() |
String |
getHealthReport() |
String |
getHostName() |
String |
getHttpAddress() |
int |
getHttpPort() |
long |
getLastHealthReportTime() |
org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse |
getLastNodeHeartBeatResponse() |
org.apache.hadoop.net.Node |
getNode() |
String |
getNodeAddress() |
org.apache.hadoop.yarn.api.records.NodeId |
getNodeID() |
String |
getNodeManagerVersion() |
String |
getRackName() |
org.apache.hadoop.yarn.api.records.ResourceOption |
getResourceOption() |
org.apache.hadoop.yarn.api.records.NodeState |
getState() |
org.apache.hadoop.yarn.api.records.Resource |
getTotalCapability() |
List<org.apache.hadoop.yarn.server.resourcemanager.rmnode.UpdatedContainerInfo> |
pullContainerUpdates() |
void |
setResourceOption(org.apache.hadoop.yarn.api.records.ResourceOption resourceOption) |
void |
updateNodeHeartbeatResponseForCleanup(org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse nodeHeartbeatResponse) |
public RMNodeWrapper(org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNode node)
public org.apache.hadoop.yarn.api.records.NodeId getNodeID()
getNodeID
in interface org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNode
public String getHostName()
getHostName
in interface org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNode
public int getCommandPort()
getCommandPort
in interface org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNode
public int getHttpPort()
getHttpPort
in interface org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNode
public String getNodeAddress()
getNodeAddress
in interface org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNode
public String getHttpAddress()
getHttpAddress
in interface org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNode
public String getHealthReport()
getHealthReport
in interface org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNode
public long getLastHealthReportTime()
getLastHealthReportTime
in interface org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNode
public org.apache.hadoop.yarn.api.records.Resource getTotalCapability()
getTotalCapability
in interface org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNode
public String getRackName()
getRackName
in interface org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNode
public org.apache.hadoop.net.Node getNode()
getNode
in interface org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNode
public org.apache.hadoop.yarn.api.records.NodeState getState()
getState
in interface org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNode
public List<org.apache.hadoop.yarn.api.records.ContainerId> getContainersToCleanUp()
getContainersToCleanUp
in interface org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNode
public List<org.apache.hadoop.yarn.api.records.ApplicationId> getAppsToCleanup()
getAppsToCleanup
in interface org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNode
public void updateNodeHeartbeatResponseForCleanup(org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse nodeHeartbeatResponse)
updateNodeHeartbeatResponseForCleanup
in interface org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNode
public org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse getLastNodeHeartBeatResponse()
getLastNodeHeartBeatResponse
in interface org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNode
public List<org.apache.hadoop.yarn.server.resourcemanager.rmnode.UpdatedContainerInfo> pullContainerUpdates()
pullContainerUpdates
in interface org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNode
public String getNodeManagerVersion()
getNodeManagerVersion
in interface org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNode
public void setResourceOption(org.apache.hadoop.yarn.api.records.ResourceOption resourceOption)
setResourceOption
in interface org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNode
public org.apache.hadoop.yarn.api.records.ResourceOption getResourceOption()
getResourceOption
in interface org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNode
Copyright © 2015 Apache Software Foundation. All Rights Reserved.