org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair

Class FSSchedulerNode

java.lang.Object

org.apache.hadoop.yarn.server.resourcemanager.scheduler.SchedulerNode

org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.FSSchedulerNode

@InterfaceAudience.Private
@InterfaceStability.Unstable
public class FSSchedulerNode
extends SchedulerNode

Constructor Summary

Constructors

Constructor and Description
FSSchedulerNode(RMNode node, boolean usePortForNodeName)

Method Summary

Methods

Modifier and Type	Method and Description
void	allocateContainer(ApplicationId applicationId, RMContainer rmContainer) The Scheduler has allocated containers on this node to the given application.
Resource	getAvailableResource() Get available resources on the node.
String	getHttpAddress()
NodeId	getNodeID()
String	getNodeName() Get the name of the node for scheduling matching decisions.
int	getNumContainers() Get number of active containers on the node.
String	getRackName() Get rackname.
AppSchedulable	getReservedAppSchedulable()
RMContainer	getReservedContainer()
RMNode	getRMNode()
List<RMContainer>	getRunningContainers()
Resource	getTotalResource() Get total resources on the node.
Resource	getUsedResource() Get used resources on the node.
void	releaseContainer(Container container) Release an allocated container on this node.
void	reserveResource(FSSchedulerApp application, Priority priority, RMContainer reservedContainer)
String	toString()
void	unreserveResource(FSSchedulerApp application)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

FSSchedulerNode

public FSSchedulerNode(RMNode node,
               boolean usePortForNodeName)

Method Detail

getRMNode

public RMNode getRMNode()

getNodeID

public NodeId getNodeID()

getHttpAddress

public String getHttpAddress()

getNodeName

public String getNodeName()

Description copied from class: SchedulerNode

Get the name of the node for scheduling matching decisions.

Typically this is the 'hostname' reported by the node, but it could be configured to be 'hostname:port' reported by the node via the YarnConfiguration.RM_SCHEDULER_INCLUDE_PORT_IN_NODE_NAME constant. The main usecase of this is Yarn minicluster to be able to differentiate node manager instances by their port number.

Specified by:

getNodeName in class SchedulerNode

Returns:

name of the node for scheduling matching decisions.

getRackName

public String getRackName()

Description copied from class: SchedulerNode

Get rackname.

Specified by:

getRackName in class SchedulerNode

Returns:

rackname

allocateContainer

public void allocateContainer(ApplicationId applicationId,
                     RMContainer rmContainer)

The Scheduler has allocated containers on this node to the given application.

Parameters:

applicationId - application

rmContainer - allocated container

getAvailableResource

public Resource getAvailableResource()

Description copied from class: SchedulerNode

Get available resources on the node.

Specified by:

getAvailableResource in class SchedulerNode

Returns:

available resources on the node

getUsedResource

public Resource getUsedResource()

Description copied from class: SchedulerNode

Get used resources on the node.

Specified by:

getUsedResource in class SchedulerNode

Returns:

used resources on the node

releaseContainer

public void releaseContainer(Container container)

Release an allocated container on this node.

Parameters:

container - container to be released

getTotalResource

public Resource getTotalResource()

Description copied from class: SchedulerNode

Get total resources on the node.

Specified by:

getTotalResource in class SchedulerNode

Returns:

total resources on the node.

toString

public String toString()

Overrides:

toString in class Object

getNumContainers

public int getNumContainers()

Description copied from class: SchedulerNode

Get number of active containers on the node.

Specified by:

getNumContainers in class SchedulerNode

Returns:

number of active containers on the node

getRunningContainers

public List<RMContainer> getRunningContainers()

reserveResource

public void reserveResource(FSSchedulerApp application,
                   Priority priority,
                   RMContainer reservedContainer)

unreserveResource

public void unreserveResource(FSSchedulerApp application)

getReservedContainer

public RMContainer getReservedContainer()

getReservedAppSchedulable

public AppSchedulable getReservedAppSchedulable()