public abstract class RegisterNodeManagerRequest extends Object
Constructor and Description |
---|
RegisterNodeManagerRequest() |
Modifier and Type | Method and Description |
---|---|
abstract int |
getHttpPort() |
abstract List<NMContainerStatus> |
getNMContainerStatuses() |
abstract String |
getNMVersion() |
abstract org.apache.hadoop.yarn.api.records.NodeId |
getNodeId() |
abstract org.apache.hadoop.yarn.api.records.Resource |
getResource() |
abstract List<org.apache.hadoop.yarn.api.records.ApplicationId> |
getRunningApplications()
We introduce this here because currently YARN RM doesn't persist nodes info
for application running.
|
static RegisterNodeManagerRequest |
newInstance(org.apache.hadoop.yarn.api.records.NodeId nodeId,
int httpPort,
org.apache.hadoop.yarn.api.records.Resource resource,
String nodeManagerVersionId,
List<NMContainerStatus> containerStatuses,
List<org.apache.hadoop.yarn.api.records.ApplicationId> runningApplications) |
abstract void |
setContainerStatuses(List<NMContainerStatus> containerStatuses) |
abstract void |
setHttpPort(int port) |
abstract void |
setNMVersion(String version) |
abstract void |
setNodeId(org.apache.hadoop.yarn.api.records.NodeId nodeId) |
abstract void |
setResource(org.apache.hadoop.yarn.api.records.Resource resource) |
abstract void |
setRunningApplications(List<org.apache.hadoop.yarn.api.records.ApplicationId> runningApplications)
Setter for
getRunningApplications() |
public static RegisterNodeManagerRequest newInstance(org.apache.hadoop.yarn.api.records.NodeId nodeId, int httpPort, org.apache.hadoop.yarn.api.records.Resource resource, String nodeManagerVersionId, List<NMContainerStatus> containerStatuses, List<org.apache.hadoop.yarn.api.records.ApplicationId> runningApplications)
public abstract org.apache.hadoop.yarn.api.records.NodeId getNodeId()
public abstract int getHttpPort()
public abstract org.apache.hadoop.yarn.api.records.Resource getResource()
public abstract String getNMVersion()
public abstract List<NMContainerStatus> getNMContainerStatuses()
public abstract List<org.apache.hadoop.yarn.api.records.ApplicationId> getRunningApplications()
When we have this running application list in node manager register request, we can recover nodes info for running applications. And then we can take actions accordingly
public abstract void setNodeId(org.apache.hadoop.yarn.api.records.NodeId nodeId)
public abstract void setHttpPort(int port)
public abstract void setResource(org.apache.hadoop.yarn.api.records.Resource resource)
public abstract void setNMVersion(String version)
public abstract void setContainerStatuses(List<NMContainerStatus> containerStatuses)
public abstract void setRunningApplications(List<org.apache.hadoop.yarn.api.records.ApplicationId> runningApplications)
getRunningApplications()
runningApplications
- running application in this nodeCopyright © 2018 Apache Software Foundation. All Rights Reserved.