Package | Description |
---|---|
org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity | |
org.apache.hadoop.yarn.server.resourcemanager.scheduler.common.fica |
Modifier and Type | Method and Description |
---|---|
FiCaSchedulerApp |
CSAssignment.getApplication() |
FiCaSchedulerApp |
CapacityScheduler.getApplicationAttempt(org.apache.hadoop.yarn.api.records.ApplicationAttemptId applicationAttemptId) |
Modifier and Type | Method and Description |
---|---|
Comparator<FiCaSchedulerApp> |
CapacityScheduler.getApplicationComparator() |
Comparator<FiCaSchedulerApp> |
CapacitySchedulerContext.getApplicationComparator() |
Set<FiCaSchedulerApp> |
LeafQueue.getApplications()
Obtain (read-only) collection of active applications.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
LeafQueue.assignToUser(org.apache.hadoop.yarn.api.records.Resource clusterResource,
String userName,
org.apache.hadoop.yarn.api.records.Resource limit,
FiCaSchedulerApp application,
boolean checkReservations,
Set<String> requestLabels) |
void |
CSQueue.attachContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource,
FiCaSchedulerApp application,
RMContainer container)
Attach a container to this queue
|
void |
LeafQueue.attachContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource,
FiCaSchedulerApp application,
RMContainer rmContainer) |
void |
ParentQueue.attachContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource,
FiCaSchedulerApp application,
RMContainer rmContainer) |
protected boolean |
LeafQueue.checkLimitsToReserve(org.apache.hadoop.yarn.api.records.Resource clusterResource,
FiCaSchedulerApp application,
org.apache.hadoop.yarn.api.records.Resource capability,
boolean needToUnreserve) |
void |
CSQueue.completedContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource,
FiCaSchedulerApp application,
FiCaSchedulerNode node,
RMContainer container,
org.apache.hadoop.yarn.api.records.ContainerStatus containerStatus,
RMContainerEventType event,
CSQueue childQueue,
boolean sortQueues)
A container assigned to the queue has completed.
|
void |
LeafQueue.completedContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource,
FiCaSchedulerApp application,
FiCaSchedulerNode node,
RMContainer rmContainer,
org.apache.hadoop.yarn.api.records.ContainerStatus containerStatus,
RMContainerEventType event,
CSQueue childQueue,
boolean sortQueues) |
void |
ParentQueue.completedContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource,
FiCaSchedulerApp application,
FiCaSchedulerNode node,
RMContainer rmContainer,
org.apache.hadoop.yarn.api.records.ContainerStatus containerStatus,
RMContainerEventType event,
CSQueue completedChildQueue,
boolean sortQueues) |
void |
CSQueue.detachContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource,
FiCaSchedulerApp application,
RMContainer container)
Detach a container from this queue
|
void |
LeafQueue.detachContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource,
FiCaSchedulerApp application,
RMContainer rmContainer) |
void |
ParentQueue.detachContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource,
FiCaSchedulerApp application,
RMContainer rmContainer) |
protected boolean |
LeafQueue.findNodeToUnreserve(org.apache.hadoop.yarn.api.records.Resource clusterResource,
FiCaSchedulerNode node,
FiCaSchedulerApp application,
org.apache.hadoop.yarn.api.records.Priority priority,
org.apache.hadoop.yarn.api.records.Resource capability) |
void |
CSQueue.finishApplicationAttempt(FiCaSchedulerApp application,
String queue)
An application attempt submitted to this queue has finished.
|
void |
LeafQueue.finishApplicationAttempt(FiCaSchedulerApp application,
String queue) |
void |
ParentQueue.finishApplicationAttempt(FiCaSchedulerApp application,
String queue) |
protected org.apache.hadoop.yarn.api.records.Resource |
LeafQueue.getHeadroom(LeafQueue.User user,
org.apache.hadoop.yarn.api.records.Resource queueCurrentLimit,
org.apache.hadoop.yarn.api.records.Resource clusterResource,
FiCaSchedulerApp application,
org.apache.hadoop.yarn.api.records.Resource required) |
void |
LeafQueue.removeApplicationAttempt(FiCaSchedulerApp application,
LeafQueue.User user) |
void |
CSQueue.submitApplicationAttempt(FiCaSchedulerApp application,
String userName)
Submit an application attempt to the queue.
|
void |
LeafQueue.submitApplicationAttempt(FiCaSchedulerApp application,
String userName) |
void |
ParentQueue.submitApplicationAttempt(FiCaSchedulerApp application,
String userName) |
Constructor and Description |
---|
CapacityHeadroomProvider(LeafQueue.User user,
LeafQueue queue,
FiCaSchedulerApp application,
org.apache.hadoop.yarn.api.records.Resource required,
org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.LeafQueue.QueueResourceLimitsInfo queueResourceLimitsInfo) |
CSAssignment(FiCaSchedulerApp application,
RMContainer excessReservation) |
Modifier and Type | Method and Description |
---|---|
static boolean |
FiCaSchedulerUtils.isBlacklisted(FiCaSchedulerApp application,
FiCaSchedulerNode node,
org.apache.commons.logging.Log LOG) |
Copyright © 2017 Apache Software Foundation. All Rights Reserved.