public class CapacitySchedulerPreemptionUtils extends Object
Constructor and Description |
---|
CapacitySchedulerPreemptionUtils() |
Modifier and Type | Method and Description |
---|---|
static void |
deductPreemptableResourcesBasedSelectedCandidates(org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.CapacitySchedulerPreemptionContext context,
Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId,Set<RMContainer>> selectedCandidates) |
static Map<String,org.apache.hadoop.yarn.api.records.Resource> |
getResToObtainByPartitionForLeafQueue(org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.CapacitySchedulerPreemptionContext context,
String queueName,
org.apache.hadoop.yarn.api.records.Resource clusterResource) |
static boolean |
isContainerAlreadySelected(RMContainer container,
Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId,Set<RMContainer>> selectedCandidates) |
static boolean |
tryPreemptContainerAndDeductResToObtain(org.apache.hadoop.yarn.util.resource.ResourceCalculator rc,
org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.CapacitySchedulerPreemptionContext context,
Map<String,org.apache.hadoop.yarn.api.records.Resource> resourceToObtainByPartitions,
RMContainer rmContainer,
org.apache.hadoop.yarn.api.records.Resource clusterResource,
Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId,Set<RMContainer>> preemptMap,
org.apache.hadoop.yarn.api.records.Resource totalPreemptionAllowed)
Invoke this method to preempt container based on resToObtain.
|
public static Map<String,org.apache.hadoop.yarn.api.records.Resource> getResToObtainByPartitionForLeafQueue(org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.CapacitySchedulerPreemptionContext context, String queueName, org.apache.hadoop.yarn.api.records.Resource clusterResource)
public static boolean isContainerAlreadySelected(RMContainer container, Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId,Set<RMContainer>> selectedCandidates)
public static void deductPreemptableResourcesBasedSelectedCandidates(org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.CapacitySchedulerPreemptionContext context, Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId,Set<RMContainer>> selectedCandidates)
public static boolean tryPreemptContainerAndDeductResToObtain(org.apache.hadoop.yarn.util.resource.ResourceCalculator rc, org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.CapacitySchedulerPreemptionContext context, Map<String,org.apache.hadoop.yarn.api.records.Resource> resourceToObtainByPartitions, RMContainer rmContainer, org.apache.hadoop.yarn.api.records.Resource clusterResource, Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId,Set<RMContainer>> preemptMap, org.apache.hadoop.yarn.api.records.Resource totalPreemptionAllowed)
rc
- resource calculatorcontext
- preemption contextresourceToObtainByPartitions
- map to hold resource to obtain per partitionrmContainer
- containerclusterResource
- total resourcepreemptMap
- map to hold preempted containerstotalPreemptionAllowed
- total preemption allowed per roundresourceToObtainByPartition
Copyright © 2017 Apache Software Foundation. All Rights Reserved.