public class FifoIntraQueuePreemptionPlugin extends Object
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 |
---|
FifoIntraQueuePreemptionPlugin(org.apache.hadoop.yarn.util.resource.ResourceCalculator rc,
org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.CapacitySchedulerPreemptionContext preemptionContext) |
Modifier and Type | Method and Description |
---|---|
void |
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) |
Collection<FiCaSchedulerApp> |
getPreemptableApps(String queueName,
String partition) |
Map<String,org.apache.hadoop.yarn.api.records.Resource> |
getResourceDemandFromAppsPerQueue(String queueName,
String partition) |
boolean |
skipContainerBasedOnIntraQueuePolicy(FiCaSchedulerApp app,
org.apache.hadoop.yarn.api.records.Resource clusterResource,
org.apache.hadoop.yarn.api.records.Resource usedResource,
RMContainer c) |
void |
validateOutSameAppPriorityFromDemand(org.apache.hadoop.yarn.api.records.Resource cluster,
TreeSet<TempAppPerPartition> orderedApps,
Map<String,TempUserPerPartition> usersPerPartition,
ProportionalCapacityPreemptionPolicy.IntraQueuePreemptionOrderPolicy intraQueuePreemptionOrder) |
protected final org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.CapacitySchedulerPreemptionContext context
protected final org.apache.hadoop.yarn.util.resource.ResourceCalculator rc
public FifoIntraQueuePreemptionPlugin(org.apache.hadoop.yarn.util.resource.ResourceCalculator rc, org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.CapacitySchedulerPreemptionContext preemptionContext)
public Collection<FiCaSchedulerApp> getPreemptableApps(String queueName, String partition)
public Map<String,org.apache.hadoop.yarn.api.records.Resource> getResourceDemandFromAppsPerQueue(String queueName, String partition)
public void 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)
public void validateOutSameAppPriorityFromDemand(org.apache.hadoop.yarn.api.records.Resource cluster, TreeSet<TempAppPerPartition> orderedApps, Map<String,TempUserPerPartition> usersPerPartition, ProportionalCapacityPreemptionPolicy.IntraQueuePreemptionOrderPolicy intraQueuePreemptionOrder)
public boolean skipContainerBasedOnIntraQueuePolicy(FiCaSchedulerApp app, org.apache.hadoop.yarn.api.records.Resource clusterResource, org.apache.hadoop.yarn.api.records.Resource usedResource, RMContainer c)
Copyright © 2017 Apache Software Foundation. All Rights Reserved.