org.apache.hadoop.yarn.server.resourcemanager.rmnode
Interface RMNode

All Known Implementing Classes:
RMNodeImpl

public interface RMNode

Node managers information on available resources and other static information.


Method Summary
 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.
 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.
 

Method Detail

getNodeID

org.apache.hadoop.yarn.api.records.NodeId getNodeID()
the node id of of this node.

Returns:
the node id of this node.

getHostName

String getHostName()
the hostname of this node

Returns:
hostname of this node

getCommandPort

int getCommandPort()
the command port for this node

Returns:
command port for this node

getHttpPort

int getHttpPort()
the http port for this node

Returns:
http port for this node

getNodeAddress

String getNodeAddress()
the ContainerManager address for this node.

Returns:
the ContainerManager address for this node.

getHttpAddress

String getHttpAddress()
the http-Address for this node.

Returns:
the http-url address for this node

getHealthReport

String getHealthReport()
the latest health report received from this node.

Returns:
the latest health report received from this node.

getLastHealthReportTime

long getLastHealthReportTime()
the time of the latest health report received from this node.

Returns:
the time of the latest health report received from this node.

getTotalCapability

org.apache.hadoop.yarn.api.records.Resource getTotalCapability()
the total available resource.

Returns:
the total available resource.

getRackName

String getRackName()
The rack name for this node manager.

Returns:
the rack name.

getNode

org.apache.hadoop.net.Node getNode()
the Node information for this node.

Returns:
Node information for this node.

getState

org.apache.hadoop.yarn.api.records.NodeState getState()

getContainersToCleanUp

List<org.apache.hadoop.yarn.api.records.ContainerId> getContainersToCleanUp()

getAppsToCleanup

List<org.apache.hadoop.yarn.api.records.ApplicationId> getAppsToCleanup()

updateNodeHeartbeatResponseForCleanup

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.

Parameters:
response - the NodeHeartbeatResponse to update

getLastNodeHeartBeatResponse

org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse getLastNodeHeartBeatResponse()

pullContainerUpdates

List<UpdatedContainerInfo> pullContainerUpdates()
Get and clear the list of containerUpdates accumulated across NM heartbeats.

Returns:
containerUpdates accumulated across NM heartbeats.


Copyright © 2014 Apache Software Foundation. All Rights Reserved.