Package | Description |
---|---|
org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair |
Modifier and Type | Method and Description |
---|---|
RMContainer |
FSAppAttempt.allocate(NodeType type,
FSSchedulerNode node,
org.apache.hadoop.yarn.api.records.Priority priority,
org.apache.hadoop.yarn.api.records.ResourceRequest request,
org.apache.hadoop.yarn.api.records.Container container) |
org.apache.hadoop.yarn.api.records.Resource |
Schedulable.assignContainer(FSSchedulerNode node)
Assign a container on this node if possible, and return the amount of
resources assigned.
|
org.apache.hadoop.yarn.api.records.Resource |
FSParentQueue.assignContainer(FSSchedulerNode node) |
org.apache.hadoop.yarn.api.records.Resource |
FSLeafQueue.assignContainer(FSSchedulerNode node) |
org.apache.hadoop.yarn.api.records.Resource |
FSAppAttempt.assignContainer(FSSchedulerNode node) |
protected boolean |
FSQueue.assignContainerPreCheck(FSSchedulerNode node)
Helper method to check if the queue should attempt assigning resources
|
boolean |
FSAppAttempt.assignReservedContainer(FSSchedulerNode node)
Called when this application already has an existing reservation on the
given node.
|
org.apache.hadoop.yarn.api.records.Container |
FSAppAttempt.createContainer(FSSchedulerNode node,
org.apache.hadoop.yarn.api.records.Resource capability,
org.apache.hadoop.yarn.api.records.Priority priority)
Create and return a container object reflecting an allocation for the
given appliction on the given node with the given capability and
priority.
|
void |
FSAppAttempt.unreserve(org.apache.hadoop.yarn.api.records.Priority priority,
FSSchedulerNode node)
Remove the reservation on
node at the given Priority . |
Copyright © 2017 Apache Software Foundation. All Rights Reserved.