Package | Description |
---|---|
org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity |
Modifier and Type | Method and Description |
---|---|
TempQueuePerPartition |
ProportionalCapacityPreemptionPolicy.getQueueByPartition(String queueName,
String partition)
Get queue partition by given queueName and partitionName
|
Modifier and Type | Method and Description |
---|---|
ArrayList<TempQueuePerPartition> |
TempQueuePerPartition.getChildren() |
Collection<TempQueuePerPartition> |
ProportionalCapacityPreemptionPolicy.getQueuePartitions(String queueName)
Get all queue partitions by given queueName
|
Modifier and Type | Method and Description |
---|---|
void |
TempQueuePerPartition.addChild(TempQueuePerPartition q)
When adding a child we also aggregate its pending resource needs.
|
void |
FifoIntraQueuePreemptionPlugin.computeAppsIdealAllocation(org.apache.hadoop.yarn.api.records.Resource clusterResource,
TempQueuePerPartition tq,
Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId,Set<RMContainer>> selectedCandidates,
org.apache.hadoop.yarn.api.records.Resource totalPreemptedResourceAllowed,
org.apache.hadoop.yarn.api.records.Resource queueReassignableResource,
float maxAllowablePreemptLimit) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractPreemptableResourceCalculator.computeFixpointAllocation(org.apache.hadoop.yarn.api.records.Resource totGuarant,
Collection<TempQueuePerPartition> qAlloc,
org.apache.hadoop.yarn.api.records.Resource unassigned,
boolean ignoreGuarantee)
Given a set of queues compute the fix-point distribution of unassigned
resources among them.
|
Copyright © 2017 Apache Software Foundation. All Rights Reserved.