|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNodeImpl
@InterfaceAudience.Private @InterfaceStability.Unstable public class RMNodeImpl
This class is used to keep track of all the applications/containers running on a node.
Nested Class Summary | |
---|---|
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
|
Constructor Summary | |
---|---|
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)
|
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. |
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. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public 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)
Method Detail |
---|
public String toString()
toString
in class Object
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
getNodeID
in interface 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.
getNode
in interface 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 org.apache.hadoop.yarn.api.records.NodeState getState()
getState
in interface RMNode
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()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |