Package org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb

Class RegisterNodeManagerRequestPBImpl

java.lang.Object

org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerRequest

org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerRequestPBImpl

public class RegisterNodeManagerRequestPBImpl
extends RegisterNodeManagerRequest

Constructor Summary

Constructors

Constructor	Description
RegisterNodeManagerRequestPBImpl()
RegisterNodeManagerRequestPBImpl(org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.RegisterNodeManagerRequestProto proto)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object other)
int	getHttpPort()
List<LogAggregationReport>	getLogAggregationReportsForApps()
List<NMContainerStatus>	getNMContainerStatuses()
String	getNMVersion()
Set<org.apache.hadoop.yarn.api.records.NodeAttribute>	getNodeAttributes()
org.apache.hadoop.yarn.api.records.NodeId	getNodeId()
Set<org.apache.hadoop.yarn.api.records.NodeLabel>	getNodeLabels()
NodeStatus	getNodeStatus()	Get the status of the node.
org.apache.hadoop.yarn.api.records.Resource	getPhysicalResource()	Get the physical resources in the node to properly estimate resource utilization.
org.apache.hadoop.yarn.proto.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	setLogAggregationReportsForApps(List<LogAggregationReport> logAggregationStatusForApps)
void	setNMVersion(String version)
void	setNodeAttributes(Set<org.apache.hadoop.yarn.api.records.NodeAttribute> nodeAttributes)
void	setNodeId(org.apache.hadoop.yarn.api.records.NodeId nodeId)
void	setNodeLabels(Set<org.apache.hadoop.yarn.api.records.NodeLabel> nodeLabels)
void	setNodeStatus(NodeStatus pNodeStatus)	Set the status of the node.
void	setPhysicalResource(org.apache.hadoop.yarn.api.records.Resource pPhysicalResource)	Set the physical resources in the node to properly estimate resource utilization.
void	setResource(org.apache.hadoop.yarn.api.records.Resource resource)
void	setRunningApplications(List<org.apache.hadoop.yarn.api.records.ApplicationId> apps)	Setter for RegisterNodeManagerRequest.getRunningApplications()

Methods inherited from class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerRequest

newInstance, newInstance, newInstance, newInstance

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RegisterNodeManagerRequestPBImpl

public RegisterNodeManagerRequestPBImpl()

RegisterNodeManagerRequestPBImpl

public RegisterNodeManagerRequestPBImpl(org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.RegisterNodeManagerRequestProto proto)

Method Details

getProto

public org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.RegisterNodeManagerRequestProto getProto()

getResource

public org.apache.hadoop.yarn.api.records.Resource getResource()

Specified by:

getResource in class RegisterNodeManagerRequest

setResource

public void setResource(org.apache.hadoop.yarn.api.records.Resource resource)

Specified by:

setResource in class RegisterNodeManagerRequest

getNodeId

public org.apache.hadoop.yarn.api.records.NodeId getNodeId()

Specified by:

getNodeId in class RegisterNodeManagerRequest

setNodeId

public void setNodeId(org.apache.hadoop.yarn.api.records.NodeId nodeId)

Specified by:

setNodeId in class RegisterNodeManagerRequest

getHttpPort

public int getHttpPort()

Specified by:

getHttpPort in class RegisterNodeManagerRequest

setHttpPort

public void setHttpPort(int httpPort)

Specified by:

setHttpPort in class RegisterNodeManagerRequest

getRunningApplications

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

Description copied from class: RegisterNodeManagerRequest

We introduce this here because currently YARN RM doesn't persist nodes info for application running. When RM restart happened, we cannot determinate if a node should do application cleanup (like log-aggregation, status update, etc.) or not.

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

Specified by:

getRunningApplications in class RegisterNodeManagerRequest

Returns:

running application list in this node

setRunningApplications

public void setRunningApplications(List<org.apache.hadoop.yarn.api.records.ApplicationId> apps)

Description copied from class: RegisterNodeManagerRequest

Setter for RegisterNodeManagerRequest.getRunningApplications()

Specified by:

setRunningApplications in class RegisterNodeManagerRequest

Parameters:

apps - running application in this node

getNMContainerStatuses

public List<NMContainerStatus> getNMContainerStatuses()

Specified by:

getNMContainerStatuses in class RegisterNodeManagerRequest

setContainerStatuses

public void setContainerStatuses(List<NMContainerStatus> containerReports)

Specified by:

setContainerStatuses in class RegisterNodeManagerRequest

getPhysicalResource

public org.apache.hadoop.yarn.api.records.Resource getPhysicalResource()

Description copied from class: RegisterNodeManagerRequest

Get the physical resources in the node to properly estimate resource utilization.

Specified by:

getPhysicalResource in class RegisterNodeManagerRequest

Returns:

Physical resources in the node.

setPhysicalResource

public void setPhysicalResource(org.apache.hadoop.yarn.api.records.Resource pPhysicalResource)

Description copied from class: RegisterNodeManagerRequest

Set the physical resources in the node to properly estimate resource utilization.

Specified by:

setPhysicalResource in class RegisterNodeManagerRequest

Parameters:

pPhysicalResource - Physical resources in the node.

getNodeStatus

public NodeStatus getNodeStatus()

Description copied from class: RegisterNodeManagerRequest

Get the status of the node.

Specified by:

getNodeStatus in class RegisterNodeManagerRequest

Returns:

The status of the node.

setNodeStatus

public void setNodeStatus(NodeStatus pNodeStatus)

Description copied from class: RegisterNodeManagerRequest

Set the status of the node.

Specified by:

setNodeStatus in class RegisterNodeManagerRequest

Parameters:

pNodeStatus - The status of the node.

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object other)

Overrides:

equals in class Object

getNMVersion

public String getNMVersion()

Specified by:

getNMVersion in class RegisterNodeManagerRequest

setNMVersion

public void setNMVersion(String version)

Specified by:

setNMVersion in class RegisterNodeManagerRequest

getNodeLabels

public Set<org.apache.hadoop.yarn.api.records.NodeLabel> getNodeLabels()

Specified by:

getNodeLabels in class RegisterNodeManagerRequest

setNodeLabels

public void setNodeLabels(Set<org.apache.hadoop.yarn.api.records.NodeLabel> nodeLabels)

Specified by:

setNodeLabels in class RegisterNodeManagerRequest

getNodeAttributes

public Set<org.apache.hadoop.yarn.api.records.NodeAttribute> getNodeAttributes()

Specified by:

getNodeAttributes in class RegisterNodeManagerRequest

setNodeAttributes

public void setNodeAttributes(Set<org.apache.hadoop.yarn.api.records.NodeAttribute> nodeAttributes)

Specified by:

setNodeAttributes in class RegisterNodeManagerRequest

getLogAggregationReportsForApps

public List<LogAggregationReport> getLogAggregationReportsForApps()

Specified by:

getLogAggregationReportsForApps in class RegisterNodeManagerRequest

setLogAggregationReportsForApps

public void setLogAggregationReportsForApps(List<LogAggregationReport> logAggregationStatusForApps)

Specified by:

setLogAggregationReportsForApps in class RegisterNodeManagerRequest