public class FiCaSchedulerNode extends SchedulerNode
Constructor and Description |
---|
FiCaSchedulerNode(RMNode node,
boolean usePortForNodeName) |
FiCaSchedulerNode(RMNode node,
boolean usePortForNodeName,
Set<String> nodeLabels) |
Modifier and Type | Method and Description |
---|---|
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, getAvailableResource, getHttpAddress, getLabels, getNodeID, getNodeName, getNumContainers, getRackName, getReservedContainer, getRMNode, getRunningContainers, getTotalResource, getUsedResource, isValidContainer, recoverContainer, releaseContainer, setReservedContainer, setTotalResource, toString, updateLabels
public FiCaSchedulerNode(RMNode node, boolean usePortForNodeName, Set<String> nodeLabels)
public FiCaSchedulerNode(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
Copyright © 2017 Apache Software Foundation. All Rights Reserved.