Package org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity

Class FifoIntraQueuePreemptionPlugin

java.lang.Object

org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.FifoIntraQueuePreemptionPlugin

public class FifoIntraQueuePreemptionPlugin
extends Object

FifoIntraQueuePreemptionPlugin will handle intra-queue preemption for priority and user-limit.

Field Summary

Fields

Modifier and Type	Field	Description
protected final CapacitySchedulerPreemptionContext	context
protected final org.apache.hadoop.yarn.util.resource.ResourceCalculator	rc

Constructor Summary

Constructors

Constructor	Description
FifoIntraQueuePreemptionPlugin(org.apache.hadoop.yarn.util.resource.ResourceCalculator rc, CapacitySchedulerPreemptionContext preemptionContext)

Method Summary

Modifier and Type	Method	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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

context

protected final CapacitySchedulerPreemptionContext context

rc

protected final org.apache.hadoop.yarn.util.resource.ResourceCalculator rc

Constructor Details

FifoIntraQueuePreemptionPlugin

public FifoIntraQueuePreemptionPlugin(org.apache.hadoop.yarn.util.resource.ResourceCalculator rc,
 CapacitySchedulerPreemptionContext preemptionContext)

Method Details

getPreemptableApps

public Collection<FiCaSchedulerApp> getPreemptableApps(String queueName,
 String partition)

getResourceDemandFromAppsPerQueue

public Map<String,org.apache.hadoop.yarn.api.records.Resource> getResourceDemandFromAppsPerQueue(String queueName,
 String partition)

computeAppsIdealAllocation

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)

validateOutSameAppPriorityFromDemand

public void validateOutSameAppPriorityFromDemand(org.apache.hadoop.yarn.api.records.Resource cluster,
 TreeSet<TempAppPerPartition> orderedApps,
 Map<String,TempUserPerPartition> usersPerPartition,
 ProportionalCapacityPreemptionPolicy.IntraQueuePreemptionOrderPolicy intraQueuePreemptionOrder)

skipContainerBasedOnIntraQueuePolicy

public boolean skipContainerBasedOnIntraQueuePolicy(FiCaSchedulerApp app,
 org.apache.hadoop.yarn.api.records.Resource clusterResource,
 org.apache.hadoop.yarn.api.records.Resource usedResource,
 RMContainer c)