public class AbstractPreemptableResourceCalculator extends Object
PreemptionCandidatesSelector
.Modifier and Type | Field and Description |
---|---|
protected org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.CapacitySchedulerPreemptionContext |
context |
protected org.apache.hadoop.yarn.util.resource.ResourceCalculator |
rc |
Constructor and Description |
---|
AbstractPreemptableResourceCalculator(org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.CapacitySchedulerPreemptionContext preemptionContext,
boolean isReservedPreemptionCandidatesSelector)
PreemptableResourceCalculator constructor.
|
Modifier and Type | Method and Description |
---|---|
protected void |
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.
|
protected final org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.CapacitySchedulerPreemptionContext context
protected final org.apache.hadoop.yarn.util.resource.ResourceCalculator rc
public AbstractPreemptableResourceCalculator(org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.CapacitySchedulerPreemptionContext preemptionContext, boolean isReservedPreemptionCandidatesSelector)
preemptionContext
- contextisReservedPreemptionCandidatesSelector
- this will be set by different implementation of candidate
selectors, please refer to TempQueuePerPartition#offer for
details.protected void computeFixpointAllocation(org.apache.hadoop.yarn.api.records.Resource totGuarant, Collection<TempQueuePerPartition> qAlloc, org.apache.hadoop.yarn.api.records.Resource unassigned, boolean ignoreGuarantee)
totGuarant
- total guaranteed resourceqAlloc
- List of child queuesunassigned
- Unassigned resource per queueignoreGuarantee
- ignore guarantee per queue.Copyright © 2017 Apache Software Foundation. All Rights Reserved.