Modifier and Type | Class and Description |
---|---|
class |
AbstractYarnScheduler<T extends SchedulerApplicationAttempt,N extends SchedulerNode> |
class |
SchedulerApplication<T extends SchedulerApplicationAttempt> |
Modifier and Type | Method and Description |
---|---|
void |
AbstractYarnScheduler.addBlacklistedNodeIdsToList(SchedulerApplicationAttempt app,
List<org.apache.hadoop.yarn.api.records.NodeId> blacklistNodeIdList)
Add blacklisted NodeIds to the list that is passed.
|
protected abstract void |
AbstractYarnScheduler.decreaseContainer(SchedContainerChangeRequest decreaseRequest,
SchedulerApplicationAttempt attempt) |
protected void |
AbstractYarnScheduler.decreaseContainers(List<org.apache.hadoop.yarn.api.records.UpdateContainerRequest> decreaseRequests,
SchedulerApplicationAttempt attempt) |
static boolean |
SchedulerAppUtils.isPlaceBlacklisted(SchedulerApplicationAttempt application,
SchedulerNode node,
org.apache.commons.logging.Log log) |
void |
Queue.recoverContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource,
SchedulerApplicationAttempt schedulerAttempt,
RMContainer rmContainer)
Recover the state of the queue for a given container.
|
protected void |
AbstractYarnScheduler.releaseContainers(List<org.apache.hadoop.yarn.api.records.ContainerId> containers,
SchedulerApplicationAttempt attempt) |
abstract void |
SchedulerNode.reserveResource(SchedulerApplicationAttempt attempt,
org.apache.hadoop.yarn.api.records.Priority priority,
RMContainer container)
Reserve container for the attempt on this node.
|
void |
SchedulerApplicationAttempt.transferStateFromPreviousAttempt(SchedulerApplicationAttempt appAttempt) |
abstract void |
SchedulerNode.unreserveResource(SchedulerApplicationAttempt attempt)
Unreserve resources on this node.
|
Constructor and Description |
---|
SchedulerAppReport(SchedulerApplicationAttempt app) |
Modifier and Type | Method and Description |
---|---|
void |
LeafQueue.decAMUsedResource(String nodeLabel,
org.apache.hadoop.yarn.api.records.Resource resourceToDec,
SchedulerApplicationAttempt application) |
protected void |
CapacityScheduler.decreaseContainer(SchedContainerChangeRequest decreaseRequest,
SchedulerApplicationAttempt attempt) |
void |
LeafQueue.decUsedResource(String nodeLabel,
org.apache.hadoop.yarn.api.records.Resource resourceToDec,
SchedulerApplicationAttempt application) |
void |
CSQueue.decUsedResource(String nodePartition,
org.apache.hadoop.yarn.api.records.Resource resourceToDec,
SchedulerApplicationAttempt application)
When partition of node updated, we will update queue's resource usage if it
has container(s) running on that.
|
void |
AbstractCSQueue.decUsedResource(String nodeLabel,
org.apache.hadoop.yarn.api.records.Resource resourceToDec,
SchedulerApplicationAttempt application) |
void |
LeafQueue.incAMUsedResource(String nodeLabel,
org.apache.hadoop.yarn.api.records.Resource resourceToInc,
SchedulerApplicationAttempt application) |
void |
LeafQueue.incUsedResource(String nodeLabel,
org.apache.hadoop.yarn.api.records.Resource resourceToInc,
SchedulerApplicationAttempt application) |
void |
CSQueue.incUsedResource(String nodePartition,
org.apache.hadoop.yarn.api.records.Resource resourceToInc,
SchedulerApplicationAttempt application)
When partition of node updated, we will update queue's resource usage if it
has container(s) running on that.
|
void |
AbstractCSQueue.incUsedResource(String nodeLabel,
org.apache.hadoop.yarn.api.records.Resource resourceToInc,
SchedulerApplicationAttempt application) |
void |
ParentQueue.recoverContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource,
SchedulerApplicationAttempt attempt,
RMContainer rmContainer) |
void |
LeafQueue.recoverContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource,
SchedulerApplicationAttempt attempt,
RMContainer rmContainer) |
Modifier and Type | Class and Description |
---|---|
class |
FiCaSchedulerApp
Represents an application attempt from the viewpoint of the FIFO or Capacity
scheduler.
|
Modifier and Type | Method and Description |
---|---|
void |
FiCaSchedulerNode.reserveResource(SchedulerApplicationAttempt application,
org.apache.hadoop.yarn.api.records.Priority priority,
RMContainer container) |
void |
FiCaSchedulerApp.transferStateFromPreviousAttempt(SchedulerApplicationAttempt appAttempt) |
void |
FiCaSchedulerNode.unreserveResource(SchedulerApplicationAttempt application) |
Modifier and Type | Class and Description |
---|---|
class |
FSAppAttempt
Represents an application attempt from the viewpoint of the Fair Scheduler.
|
Modifier and Type | Method and Description |
---|---|
protected void |
FairScheduler.decreaseContainer(SchedContainerChangeRequest decreaseRequest,
SchedulerApplicationAttempt attempt) |
void |
FSParentQueue.recoverContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource,
SchedulerApplicationAttempt schedulerAttempt,
RMContainer rmContainer) |
void |
FSLeafQueue.recoverContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource,
SchedulerApplicationAttempt schedulerAttempt,
RMContainer rmContainer) |
void |
FSSchedulerNode.reserveResource(SchedulerApplicationAttempt application,
org.apache.hadoop.yarn.api.records.Priority priority,
RMContainer container) |
void |
FSSchedulerNode.unreserveResource(SchedulerApplicationAttempt application) |
Modifier and Type | Method and Description |
---|---|
protected void |
FifoScheduler.decreaseContainer(SchedContainerChangeRequest decreaseRequest,
SchedulerApplicationAttempt attempt) |
Copyright © 2017 Apache Software Foundation. All Rights Reserved.