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

Class PreemptionCandidatesSelector

java.lang.Object

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

Direct Known Subclasses:

FifoCandidatesSelector, IntraQueueCandidatesSelector, ReservedContainerCandidatesSelector

public abstract class PreemptionCandidatesSelector
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.CapacitySchedulerPreemptionContext	preemptionContext
protected org.apache.hadoop.yarn.util.resource.ResourceCalculator	rc

Method Summary

Methods

Modifier and Type	Method and Description
abstract Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId,Set<RMContainer>>	selectCandidates(Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId,Set<RMContainer>> selectedCandidates, org.apache.hadoop.yarn.api.records.Resource clusterResource, org.apache.hadoop.yarn.api.records.Resource totalPreemptedResourceAllowed) Get preemption candidates from computed resource sharing and already selected candidates.

Methods inherited from class java.lang.Object

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

Field Detail

preemptionContext

protected org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.CapacitySchedulerPreemptionContext preemptionContext

rc

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

Method Detail

selectCandidates

public abstract Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId,Set<RMContainer>> selectCandidates(Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId,Set<RMContainer>> selectedCandidates,
                                                                                             org.apache.hadoop.yarn.api.records.Resource clusterResource,
                                                                                             org.apache.hadoop.yarn.api.records.Resource totalPreemptedResourceAllowed)

Get preemption candidates from computed resource sharing and already selected candidates.

Parameters:

selectedCandidates - already selected candidates from previous policies

clusterResource - total resource

totalPreemptedResourceAllowed - how many resources allowed to be preempted in this round

Returns:

merged selected candidates.