public class RegisterNodeManagerRequestPBImpl extends RegisterNodeManagerRequest
Constructor and Description |
---|
RegisterNodeManagerRequestPBImpl() |
RegisterNodeManagerRequestPBImpl(YarnServerCommonServiceProtos.RegisterNodeManagerRequestProto proto) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object other) |
int |
getHttpPort() |
List<NMContainerStatus> |
getNMContainerStatuses() |
String |
getNMVersion() |
org.apache.hadoop.yarn.api.records.NodeId |
getNodeId() |
YarnServerCommonServiceProtos.RegisterNodeManagerRequestProto |
getProto() |
org.apache.hadoop.yarn.api.records.Resource |
getResource() |
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.
|
int |
hashCode() |
void |
setContainerStatuses(List<NMContainerStatus> containerReports) |
void |
setHttpPort(int httpPort) |
void |
setNMVersion(String version) |
void |
setNodeId(org.apache.hadoop.yarn.api.records.NodeId nodeId) |
void |
setResource(org.apache.hadoop.yarn.api.records.Resource resource) |
void |
setRunningApplications(List<org.apache.hadoop.yarn.api.records.ApplicationId> apps)
|
newInstance
public RegisterNodeManagerRequestPBImpl()
public RegisterNodeManagerRequestPBImpl(YarnServerCommonServiceProtos.RegisterNodeManagerRequestProto proto)
public YarnServerCommonServiceProtos.RegisterNodeManagerRequestProto getProto()
public org.apache.hadoop.yarn.api.records.Resource getResource()
getResource
in class RegisterNodeManagerRequest
public void setResource(org.apache.hadoop.yarn.api.records.Resource resource)
setResource
in class RegisterNodeManagerRequest
public org.apache.hadoop.yarn.api.records.NodeId getNodeId()
getNodeId
in class RegisterNodeManagerRequest
public void setNodeId(org.apache.hadoop.yarn.api.records.NodeId nodeId)
setNodeId
in class RegisterNodeManagerRequest
public int getHttpPort()
getHttpPort
in class RegisterNodeManagerRequest
public void setHttpPort(int httpPort)
setHttpPort
in class RegisterNodeManagerRequest
public List<org.apache.hadoop.yarn.api.records.ApplicationId> getRunningApplications()
RegisterNodeManagerRequest
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
getRunningApplications
in class RegisterNodeManagerRequest
public void setRunningApplications(List<org.apache.hadoop.yarn.api.records.ApplicationId> apps)
RegisterNodeManagerRequest
setRunningApplications
in class RegisterNodeManagerRequest
apps
- running application in this nodepublic List<NMContainerStatus> getNMContainerStatuses()
getNMContainerStatuses
in class RegisterNodeManagerRequest
public void setContainerStatuses(List<NMContainerStatus> containerReports)
setContainerStatuses
in class RegisterNodeManagerRequest
public String getNMVersion()
getNMVersion
in class RegisterNodeManagerRequest
public void setNMVersion(String version)
setNMVersion
in class RegisterNodeManagerRequest
Copyright © 2018 Apache Software Foundation. All Rights Reserved.