Package 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	Description
FiCaSchedulerNode(RMNode node, boolean usePortForNodeName)
FiCaSchedulerNode(RMNode node, boolean usePortForNodeName, Set<String> nodeLabels)

Method Summary

Modifier and Type	Method	Description
protected void	allocateContainer(RMContainer rmContainer, boolean launchedOnNode)	The Scheduler has allocated containers on this node to the given application.
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.server.scheduler.SchedulerRequestKey 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)	Update the resources of the node when releasing a container.

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

allocateContainer, containerStarted, deductUnallocatedResource, equals, getAggregatedContainersUtilization, getAllocatedResource, getContainer, getContainersToKill, getCopiedListOfRunningContainers, getHttpAddress, getLabels, getLastHeartbeatMonotonicTime, getLaunchedContainers, getNodeAttributes, getNodeID, getNodeName, getNodeUtilization, getNumContainers, getPartition, getRackName, getReservedContainer, getRMNode, getRunningContainersWithAMsAtTheEnd, getTotalResource, getUnallocatedResource, hashCode, isOvercommitTimedOut, isOvercommitTimeOutSet, isValidContainer, notifyNodeUpdate, recoverContainer, releaseContainer, setAggregatedContainersUtilization, setNodeUtilization, setOvercommitTimeOut, setReservedContainer, toString, updateLabels, updateNodeAttributes, updateTotalResource

Methods inherited from class java.lang.Object

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

Constructor Details

FiCaSchedulerNode

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

FiCaSchedulerNode

public FiCaSchedulerNode(RMNode node,
 boolean usePortForNodeName)

Method Details

reserveResource

public void reserveResource(SchedulerApplicationAttempt application,
 org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey priority,
 RMContainer container)

Description copied from class: SchedulerNode

Reserve container for the attempt on this node.

Specified by:

reserveResource in class SchedulerNode

Parameters:

application - Application attempt asking for the reservation.

priority - Priority of the reservation.

container - Container reserving resources for.

unreserveResource

public void unreserveResource(SchedulerApplicationAttempt application)

Description copied from class: SchedulerNode

Unreserve resources on this node.

Specified by:

unreserveResource in class SchedulerNode

Parameters:

application - Application attempt that had done the reservation.

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)

Description copied from class: SchedulerNode

Update the resources of the node when releasing a container.

Overrides:

updateResourceForReleasedContainer in class SchedulerNode

Parameters:

container - Container to release.

getTotalKillableResources

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

getKillableContainers

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

allocateContainer

protected void allocateContainer(RMContainer rmContainer,
 boolean launchedOnNode)

Description copied from class: SchedulerNode

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

Overrides:

allocateContainer in class SchedulerNode

Parameters:

rmContainer - Allocated container

launchedOnNode - True if the container has been launched