@InterfaceAudience.Private @InterfaceStability.Unstable public class FSSchedulerNode extends SchedulerNode
Constructor and Description |
---|
FSSchedulerNode(RMNode node,
boolean usePortForNodeName) |
Modifier and Type | Method and Description |
---|---|
FSAppAttempt |
getReservedAppSchedulable() |
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.
|
allocateContainer, changeContainerResource, 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, updateResourceForReleasedContainer, updateTotalResource
public FSSchedulerNode(RMNode node, boolean usePortForNodeName)
public void reserveResource(SchedulerApplicationAttempt application, org.apache.hadoop.yarn.api.records.Priority priority, RMContainer container)
SchedulerNode
reserveResource
in class SchedulerNode
public void unreserveResource(SchedulerApplicationAttempt application)
SchedulerNode
unreserveResource
in class SchedulerNode
public FSAppAttempt getReservedAppSchedulable()
Copyright © 2017 Apache Software Foundation. All Rights Reserved.