@InterfaceAudience.Private @InterfaceStability.Unstable public class RMNodeImpl extends Object implements RMNode, EventHandler<RMNodeEvent>
Modifier and Type | Class and Description |
---|---|
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 and Description |
---|
RMNodeImpl(NodeId nodeId,
RMContext context,
String hostName,
int cmPort,
int httpPort,
Node node,
Resource capability) |
Modifier and Type | Method and Description |
---|---|
List<ApplicationId> |
getAppsToCleanup() |
int |
getCommandPort()
the command port for this node
|
List<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.
|
NodeHeartbeatResponse |
getLastNodeHeartBeatResponse() |
Node |
getNode()
the
Node information for this node. |
String |
getNodeAddress()
the ContainerManager address for this node.
|
NodeId |
getNodeID()
the node id of of this node.
|
int |
getQueueSize() |
String |
getRackName()
The rack name for this node manager.
|
NodeState |
getState() |
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(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 NodeId getNodeID()
RMNode
public String getNodeAddress()
RMNode
getNodeAddress
in interface RMNode
public String getHttpAddress()
RMNode
getHttpAddress
in interface RMNode
public Resource getTotalCapability()
RMNode
getTotalCapability
in interface RMNode
public String getRackName()
RMNode
getRackName
in interface RMNode
public 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 List<ApplicationId> getAppsToCleanup()
getAppsToCleanup
in interface RMNode
public List<ContainerId> getContainersToCleanUp()
getContainersToCleanUp
in interface RMNode
public void updateNodeHeartbeatResponseForCleanup(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 NodeHeartbeatResponse getLastNodeHeartBeatResponse()
getLastNodeHeartBeatResponse
in interface RMNode
public void handle(RMNodeEvent event)
handle
in interface EventHandler<RMNodeEvent>
public List<UpdatedContainerInfo> pullContainerUpdates()
RMNode
pullContainerUpdates
in interface RMNode
public void setNextHeartBeat(boolean nextHeartBeat)
public int getQueueSize()
Copyright © 2013 Apache Software Foundation. All rights reserved.