Modifier and Type | Method and Description |
---|---|
static void |
RMServerUtils.checkSchedContainerChangeRequest(SchedContainerChangeRequest request,
boolean increase)
Validate increase/decrease request.
|
Modifier and Type | Method and Description |
---|---|
SchedContainerChangeRequest |
AppSchedulingInfo.getIncreaseRequest(org.apache.hadoop.yarn.api.records.NodeId nodeId,
org.apache.hadoop.yarn.api.records.Priority priority,
org.apache.hadoop.yarn.api.records.ContainerId containerId) |
Modifier and Type | Method and Description |
---|---|
protected List<SchedContainerChangeRequest> |
AbstractYarnScheduler.createSchedContainerChangeRequests(List<org.apache.hadoop.yarn.api.records.UpdateContainerRequest> changeRequests,
boolean increase) |
Map<org.apache.hadoop.yarn.api.records.ContainerId,SchedContainerChangeRequest> |
AppSchedulingInfo.getIncreaseRequests(org.apache.hadoop.yarn.api.records.NodeId nodeId,
org.apache.hadoop.yarn.api.records.Priority priority) |
Modifier and Type | Method and Description |
---|---|
int |
SchedContainerChangeRequest.compareTo(SchedContainerChangeRequest other) |
void |
SchedulerApplicationAttempt.decreaseContainer(SchedContainerChangeRequest decreaseRequest) |
void |
AppSchedulingInfo.decreaseContainer(SchedContainerChangeRequest decreaseRequest) |
protected abstract void |
AbstractYarnScheduler.decreaseContainer(SchedContainerChangeRequest decreaseRequest,
SchedulerApplicationAttempt attempt) |
void |
SchedulerApplicationAttempt.increaseContainer(SchedContainerChangeRequest increaseRequest) |
void |
AppSchedulingInfo.increaseContainer(SchedContainerChangeRequest increaseRequest) |
Modifier and Type | Method and Description |
---|---|
boolean |
SchedulerApplicationAttempt.updateIncreaseRequests(List<SchedContainerChangeRequest> increaseRequests) |
boolean |
AppSchedulingInfo.updateIncreaseRequests(List<SchedContainerChangeRequest> increaseRequests)
return true if any of the existing increase requests are updated,
false if none of them are updated
|
Modifier and Type | Method and Description |
---|---|
void |
ParentQueue.decreaseContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource,
SchedContainerChangeRequest decreaseRequest,
FiCaSchedulerApp app) |
void |
LeafQueue.decreaseContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource,
SchedContainerChangeRequest decreaseRequest,
FiCaSchedulerApp app) |
void |
CSQueue.decreaseContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource,
SchedContainerChangeRequest decreaseRequest,
FiCaSchedulerApp app)
Decrease container resource in the queue
|
protected void |
CapacityScheduler.decreaseContainer(SchedContainerChangeRequest decreaseRequest,
SchedulerApplicationAttempt attempt) |
Modifier and Type | Method and Description |
---|---|
protected void |
FairScheduler.decreaseContainer(SchedContainerChangeRequest decreaseRequest,
SchedulerApplicationAttempt attempt) |
Modifier and Type | Method and Description |
---|---|
protected void |
FifoScheduler.decreaseContainer(SchedContainerChangeRequest decreaseRequest,
SchedulerApplicationAttempt attempt) |
Copyright © 2017 Apache Software Foundation. All Rights Reserved.