public interface RMNode
Modifier and Type | Field and Description |
---|---|
static int |
OVER_COMMIT_TIMEOUT_MILLIS_DEFAULT
negative value means no timeout
|
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() |
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
|
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.
|
List<UpdatedContainerInfo> |
pullContainerUpdates()
Get and clear the list of containerUpdates accumulated across NM
heartbeats.
|
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. |
static final int OVER_COMMIT_TIMEOUT_MILLIS_DEFAULT
org.apache.hadoop.yarn.api.records.NodeId getNodeID()
String getHostName()
int getCommandPort()
int getHttpPort()
String getNodeAddress()
String getHttpAddress()
String getHealthReport()
long getLastHealthReportTime()
String getNodeManagerVersion()
org.apache.hadoop.yarn.api.records.Resource getTotalCapability()
String getRackName()
org.apache.hadoop.net.Node getNode()
Node
information for this node.Node
information for this node.org.apache.hadoop.yarn.api.records.NodeState getState()
List<org.apache.hadoop.yarn.api.records.ContainerId> getContainersToCleanUp()
List<org.apache.hadoop.yarn.api.records.ApplicationId> getAppsToCleanup()
void updateNodeHeartbeatResponseForCleanup(org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse response)
NodeHeartbeatResponse
with the list of containers and
applications to clean up for this node.response
- the NodeHeartbeatResponse
to updateorg.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse getLastNodeHeartBeatResponse()
List<UpdatedContainerInfo> pullContainerUpdates()
Copyright © 2015 Apache Software Foundation. All Rights Reserved.