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

Class ReservedContainerCandidatesSelector

java.lang.Object

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

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

public class ReservedContainerCandidatesSelector
extends PreemptionCandidatesSelector

Field Summary

Fields inherited from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.PreemptionCandidatesSelector

preemptionContext, rc

Method Summary

Methods

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

Method Detail

selectCandidates

public 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)

Description copied from class: PreemptionCandidatesSelector

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

Specified by:

selectCandidates in class PreemptionCandidatesSelector

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.