@InterfaceAudience.Private @InterfaceStability.Unstable public class RMNodeImpl extends Object implements RMNode, org.apache.hadoop.yarn.event.EventHandler<RMNodeEvent>
Modifier and Type | Class and Description |
---|---|
static class |
RMNodeImpl.AddContainersToBeRemovedFromNMTransition |
static class |
RMNodeImpl.AddNodeTransition |
static class |
RMNodeImpl.CleanUpAppTransition |
static class |
RMNodeImpl.CleanUpContainerTransition |
static class |
RMNodeImpl.DeactivateNodeTransition |
static class |
RMNodeImpl.ReconnectNodeTransition |
static class |
RMNodeImpl.StatusUpdateWhenHealthyTransition |
static class |
RMNodeImpl.StatusUpdateWhenUnHealthyTransition |
static class |
RMNodeImpl.UpdateNodeResourceWhenRunningTransition |
static class |
RMNodeImpl.UpdateNodeResourceWhenUnusableTransition |
OVER_COMMIT_TIMEOUT_MILLIS_DEFAULT
Constructor and Description |
---|
RMNodeImpl(org.apache.hadoop.yarn.api.records.NodeId nodeId,
RMContext context,
String hostName,
int cmPort,
int httpPort,
org.apache.hadoop.net.Node node,
org.apache.hadoop.yarn.api.records.Resource capability,
String nodeManagerVersion) |
Modifier and Type | Method and Description |
---|---|
List<org.apache.hadoop.yarn.api.records.ApplicationId> |
getAppsToCleanup() |
int |
getCommandPort()
the command port for this node
|
List<org.apache.hadoop.yarn.api.records.ContainerId> |
getContainersToCleanUp() |
String |
getHealthReport()
the latest health report received from this node.
|
String |
getHostName()
the hostname of this node
|
String |
getHttpAddress()
the http-Address for this node.
|
int |
getHttpPort()
the http port for this node
|
long |
getLastHealthReportTime()
the time of the latest health report received from this node.
|
org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse |
getLastNodeHeartBeatResponse() |
Set<org.apache.hadoop.yarn.api.records.ContainerId> |
getLaunchedContainers() |
org.apache.hadoop.net.Node |
getNode()
the
Node information for this node. |
String |
getNodeAddress()
the ContainerManager address for this node.
|
org.apache.hadoop.yarn.api.records.NodeId |
getNodeID()
the node id of of this node.
|
Set<String> |
getNodeLabels()
Get set of labels in this node
|
String |
getNodeManagerVersion()
the node manager version of the node received as part of the
registration with the resource manager
|
int |
getQueueSize() |
String |
getRackName()
The rack name for this node manager.
|
org.apache.hadoop.yarn.api.records.NodeState |
getState() |
org.apache.hadoop.yarn.api.records.Resource |
getTotalCapability()
the total available resource.
|
void |
handle(RMNodeEvent event) |
List<UpdatedContainerInfo> |
pullContainerUpdates()
Get and clear the list of containerUpdates accumulated across NM
heartbeats.
|
void |
setHealthReport(String healthReport) |
void |
setLastHealthReportTime(long lastHealthReportTime) |
void |
setNextHeartBeat(boolean nextHeartBeat) |
String |
toString() |
void |
updateNodeHeartbeatResponseForCleanup(org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse response)
Update a
NodeHeartbeatResponse with the list of containers and
applications to clean up for this node. |
public String getHostName()
RMNode
getHostName
in interface RMNode
public int getCommandPort()
RMNode
getCommandPort
in interface RMNode
public int getHttpPort()
RMNode
getHttpPort
in interface RMNode
public org.apache.hadoop.yarn.api.records.NodeId getNodeID()
RMNode
public String getNodeAddress()
RMNode
getNodeAddress
in interface RMNode
public String getHttpAddress()
RMNode
getHttpAddress
in interface RMNode
public org.apache.hadoop.yarn.api.records.Resource getTotalCapability()
RMNode
getTotalCapability
in interface RMNode
public String getRackName()
RMNode
getRackName
in interface RMNode
public org.apache.hadoop.net.Node getNode()
RMNode
Node
information for this node.public String getHealthReport()
RMNode
getHealthReport
in interface RMNode
public void setHealthReport(String healthReport)
public void setLastHealthReportTime(long lastHealthReportTime)
public long getLastHealthReportTime()
RMNode
getLastHealthReportTime
in interface RMNode
public String getNodeManagerVersion()
RMNode
getNodeManagerVersion
in interface RMNode
public org.apache.hadoop.yarn.api.records.NodeState getState()
public List<org.apache.hadoop.yarn.api.records.ApplicationId> getAppsToCleanup()
getAppsToCleanup
in interface RMNode
public List<org.apache.hadoop.yarn.api.records.ContainerId> getContainersToCleanUp()
getContainersToCleanUp
in interface RMNode
public void updateNodeHeartbeatResponseForCleanup(org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse response)
RMNode
NodeHeartbeatResponse
with the list of containers and
applications to clean up for this node.updateNodeHeartbeatResponseForCleanup
in interface RMNode
response
- the NodeHeartbeatResponse
to updatepublic org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse getLastNodeHeartBeatResponse()
getLastNodeHeartBeatResponse
in interface RMNode
public void handle(RMNodeEvent event)
handle
in interface org.apache.hadoop.yarn.event.EventHandler<RMNodeEvent>
public List<UpdatedContainerInfo> pullContainerUpdates()
RMNode
pullContainerUpdates
in interface RMNode
public void setNextHeartBeat(boolean nextHeartBeat)
public int getQueueSize()
public Set<org.apache.hadoop.yarn.api.records.ContainerId> getLaunchedContainers()
public Set<String> getNodeLabels()
RMNode
getNodeLabels
in interface RMNode
Copyright © 2015 Apache Software Foundation. All Rights Reserved.