Package | Description |
---|---|
org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair | |
org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.policies |
Modifier and Type | Field and Description |
---|---|
static SchedulingPolicy |
SchedulingPolicy.DEFAULT_POLICY |
protected SchedulingPolicy |
FSQueue.policy |
Modifier and Type | Method and Description |
---|---|
SchedulingPolicy |
AllocationConfiguration.getDefaultSchedulingPolicy() |
static SchedulingPolicy |
SchedulingPolicy.getInstance(Class<? extends SchedulingPolicy> clazz)
Returns a
SchedulingPolicy instance corresponding to the passed clazz |
SchedulingPolicy |
FSQueue.getPolicy() |
SchedulingPolicy |
AllocationConfiguration.getSchedulingPolicy(String queueName) |
static SchedulingPolicy |
SchedulingPolicy.parse(String policy)
Returns
SchedulingPolicy instance corresponding to the
SchedulingPolicy passed as a string. |
Modifier and Type | Method and Description |
---|---|
static boolean |
SchedulingPolicy.isApplicableTo(SchedulingPolicy policy,
byte depth)
Checks if the specified
SchedulingPolicy can be used for a queue at
the specified depth in the hierarchy |
abstract void |
FSQueue.setPolicy(SchedulingPolicy policy) |
void |
FSParentQueue.setPolicy(SchedulingPolicy policy) |
void |
FSLeafQueue.setPolicy(SchedulingPolicy policy) |
protected void |
FSQueue.throwPolicyDoesnotApplyException(SchedulingPolicy policy) |
Modifier and Type | Method and Description |
---|---|
static SchedulingPolicy |
SchedulingPolicy.getInstance(Class<? extends SchedulingPolicy> clazz)
Returns a
SchedulingPolicy instance corresponding to the passed clazz |
Constructor and Description |
---|
AllocationConfiguration(Map<String,org.apache.hadoop.yarn.api.records.Resource> minQueueResources,
Map<String,org.apache.hadoop.yarn.api.records.Resource> maxQueueResources,
Map<String,Integer> queueMaxApps,
Map<String,Integer> userMaxApps,
Map<String,ResourceWeights> queueWeights,
Map<String,Float> queueMaxAMShares,
int userMaxAppsDefault,
int queueMaxAppsDefault,
org.apache.hadoop.yarn.api.records.Resource queueMaxResourcesDefault,
float queueMaxAMShareDefault,
Map<String,SchedulingPolicy> schedulingPolicies,
SchedulingPolicy defaultSchedulingPolicy,
Map<String,Long> minSharePreemptionTimeouts,
Map<String,Long> fairSharePreemptionTimeouts,
Map<String,Float> fairSharePreemptionThresholds,
Map<String,Map<org.apache.hadoop.yarn.api.records.QueueACL,org.apache.hadoop.security.authorize.AccessControlList>> queueAcls,
Map<String,Map<org.apache.hadoop.yarn.api.records.ReservationACL,org.apache.hadoop.security.authorize.AccessControlList>> resAcls,
QueuePlacementPolicy placementPolicy,
Map<FSQueueType,Set<String>> configuredQueues,
ReservationQueueConfiguration globalReservationQueueConfig,
Set<String> reservableQueues) |
Constructor and Description |
---|
AllocationConfiguration(Map<String,org.apache.hadoop.yarn.api.records.Resource> minQueueResources,
Map<String,org.apache.hadoop.yarn.api.records.Resource> maxQueueResources,
Map<String,Integer> queueMaxApps,
Map<String,Integer> userMaxApps,
Map<String,ResourceWeights> queueWeights,
Map<String,Float> queueMaxAMShares,
int userMaxAppsDefault,
int queueMaxAppsDefault,
org.apache.hadoop.yarn.api.records.Resource queueMaxResourcesDefault,
float queueMaxAMShareDefault,
Map<String,SchedulingPolicy> schedulingPolicies,
SchedulingPolicy defaultSchedulingPolicy,
Map<String,Long> minSharePreemptionTimeouts,
Map<String,Long> fairSharePreemptionTimeouts,
Map<String,Float> fairSharePreemptionThresholds,
Map<String,Map<org.apache.hadoop.yarn.api.records.QueueACL,org.apache.hadoop.security.authorize.AccessControlList>> queueAcls,
Map<String,Map<org.apache.hadoop.yarn.api.records.ReservationACL,org.apache.hadoop.security.authorize.AccessControlList>> resAcls,
QueuePlacementPolicy placementPolicy,
Map<FSQueueType,Set<String>> configuredQueues,
ReservationQueueConfiguration globalReservationQueueConfig,
Set<String> reservableQueues) |
Modifier and Type | Class and Description |
---|---|
class |
DominantResourceFairnessPolicy
Makes scheduling decisions by trying to equalize dominant resource usage.
|
class |
FairSharePolicy
Makes scheduling decisions by trying to equalize shares of memory.
|
class |
FifoPolicy |
Copyright © 2017 Apache Software Foundation. All Rights Reserved.