org.apache.hadoop.yarn.server.resourcemanager.scheduler.common.fica

Class FiCaSchedulerNode

java.lang.Object

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

org.apache.hadoop.yarn.server.resourcemanager.scheduler.common.fica.FiCaSchedulerNode

public class FiCaSchedulerNode
extends SchedulerNode

Constructor Summary

Constructors

Constructor and Description
FiCaSchedulerNode(RMNode node, boolean usePortForNodeName)
FiCaSchedulerNode(RMNode node, boolean usePortForNodeName, Set<String> nodeLabels)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	changeContainerResource(org.apache.hadoop.yarn.api.records.ContainerId containerId, org.apache.hadoop.yarn.api.records.Resource deltaResource, boolean increase)
Map<org.apache.hadoop.yarn.api.records.ContainerId,RMContainer>	getKillableContainers()
org.apache.hadoop.yarn.api.records.Resource	getTotalKillableResources()
void	markContainerToKillable(org.apache.hadoop.yarn.api.records.ContainerId containerId)
void	markContainerToNonKillable(org.apache.hadoop.yarn.api.records.ContainerId containerId)
void	reserveResource(SchedulerApplicationAttempt application, org.apache.hadoop.yarn.api.records.Priority priority, RMContainer container) Reserve container for the attempt on this node.
void	unreserveResource(SchedulerApplicationAttempt application) Unreserve resources on this node.
protected void	updateResourceForReleasedContainer(org.apache.hadoop.yarn.api.records.Container container)

Methods inherited from class org.apache.hadoop.yarn.server.resourcemanager.scheduler.SchedulerNode

allocateContainer, containerStarted, decreaseContainer, getAggregatedContainersUtilization, getAvailableResource, getContainer, getCopiedListOfRunningContainers, getHttpAddress, getLabels, getNodeID, getNodeName, getNodeUtilization, getNumContainers, getPartition, getRackName, getReservedContainer, getRMNode, getTotalResource, getUsedResource, increaseContainer, isValidContainer, recoverContainer, releaseContainer, setAggregatedContainersUtilization, setNodeUtilization, setReservedContainer, toString, updateLabels, updateTotalResource

Methods inherited from class java.lang.Object

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

Constructor Detail

FiCaSchedulerNode

public FiCaSchedulerNode(RMNode node,
                 boolean usePortForNodeName,
                 Set<String> nodeLabels)

FiCaSchedulerNode

public FiCaSchedulerNode(RMNode node,
                 boolean usePortForNodeName)

Method Detail

reserveResource

public void reserveResource(SchedulerApplicationAttempt application,
                   org.apache.hadoop.yarn.api.records.Priority priority,
                   RMContainer container)

Description copied from class: SchedulerNode

Reserve container for the attempt on this node.

Specified by:

reserveResource in class SchedulerNode

unreserveResource

public void unreserveResource(SchedulerApplicationAttempt application)

Description copied from class: SchedulerNode

Unreserve resources on this node.

Specified by:

unreserveResource in class SchedulerNode

markContainerToKillable

public void markContainerToKillable(org.apache.hadoop.yarn.api.records.ContainerId containerId)

markContainerToNonKillable

public void markContainerToNonKillable(org.apache.hadoop.yarn.api.records.ContainerId containerId)

updateResourceForReleasedContainer

protected void updateResourceForReleasedContainer(org.apache.hadoop.yarn.api.records.Container container)

Overrides:

updateResourceForReleasedContainer in class SchedulerNode

changeContainerResource

protected void changeContainerResource(org.apache.hadoop.yarn.api.records.ContainerId containerId,
                           org.apache.hadoop.yarn.api.records.Resource deltaResource,
                           boolean increase)

Overrides:

changeContainerResource in class SchedulerNode

getTotalKillableResources

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

getKillableContainers

public Map<org.apache.hadoop.yarn.api.records.ContainerId,RMContainer> getKillableContainers()