List<org.apache.hadoop.yarn.api.records.ResourceRequest> |
AppSchedulingInfo.allocate(NodeType type,
SchedulerNode 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)
Resources have been allocated to this application by the resource
scheduler.
|
protected void |
AbstractYarnScheduler.containerLaunchedOnNode(org.apache.hadoop.yarn.api.records.ContainerId containerId,
SchedulerNode node) |
static boolean |
SchedulerAppUtils.isBlacklisted(SchedulerApplicationAttempt application,
SchedulerNode node,
org.apache.commons.logging.Log LOG) |
boolean |
AppSchedulingInfo.isBlacklisted(SchedulerNode node,
org.apache.commons.logging.Log myLog) |
boolean |
SchedulerApplicationAttempt.isBlacklisted(SchedulerNode node,
org.apache.commons.logging.Log myLog) |
boolean |
SchedulerApplicationAttempt.isReserved(SchedulerNode node,
org.apache.hadoop.yarn.api.records.Priority priority)
Has the application reserved the given node at the
given priority ?
|
RMContainer |
SchedulerApplicationAttempt.reserve(SchedulerNode node,
org.apache.hadoop.yarn.api.records.Priority priority,
RMContainer rmContainer,
org.apache.hadoop.yarn.api.records.Container container) |
protected void |
AbstractYarnScheduler.updateMaximumAllocation(SchedulerNode node,
boolean add) |