Package | Description |
---|---|
org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair |
Modifier and Type | Method and Description |
---|---|
static FSQueueType |
FSQueueType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static FSQueueType[] |
FSQueueType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
Map<FSQueueType,Set<String>> |
AllocationConfiguration.getConfiguredQueues() |
Modifier and Type | Method and Description |
---|---|
String |
QueuePlacementRule.assignAppToQueue(String requestedQueue,
String user,
org.apache.hadoop.security.Groups groups,
Map<FSQueueType,Set<String>> configuredQueues) |
String |
QueuePlacementRule.Reject.assignAppToQueue(String requestedQueue,
String user,
org.apache.hadoop.security.Groups groups,
Map<FSQueueType,Set<String>> configuredQueues) |
static QueuePlacementPolicy |
QueuePlacementPolicy.fromConfiguration(org.apache.hadoop.conf.Configuration conf,
Map<FSQueueType,Set<String>> configuredQueues)
Build a simple queue placement policy from the allow-undeclared-pools and
user-as-default-queue configuration options.
|
static QueuePlacementPolicy |
QueuePlacementPolicy.fromXml(Element el,
Map<FSQueueType,Set<String>> configuredQueues,
org.apache.hadoop.conf.Configuration conf)
Builds a QueuePlacementPolicy from an xml element.
|
protected abstract String |
QueuePlacementRule.getQueueForApp(String requestedQueue,
String user,
org.apache.hadoop.security.Groups groups,
Map<FSQueueType,Set<String>> configuredQueues)
Applies this rule to an app with the given requested queue and user/group
information.
|
protected String |
QueuePlacementRule.User.getQueueForApp(String requestedQueue,
String user,
org.apache.hadoop.security.Groups groups,
Map<FSQueueType,Set<String>> configuredQueues) |
protected String |
QueuePlacementRule.PrimaryGroup.getQueueForApp(String requestedQueue,
String user,
org.apache.hadoop.security.Groups groups,
Map<FSQueueType,Set<String>> configuredQueues) |
protected String |
QueuePlacementRule.SecondaryGroupExistingQueue.getQueueForApp(String requestedQueue,
String user,
org.apache.hadoop.security.Groups groups,
Map<FSQueueType,Set<String>> configuredQueues) |
protected String |
QueuePlacementRule.NestedUserQueue.getQueueForApp(String requestedQueue,
String user,
org.apache.hadoop.security.Groups groups,
Map<FSQueueType,Set<String>> configuredQueues) |
protected String |
QueuePlacementRule.Specified.getQueueForApp(String requestedQueue,
String user,
org.apache.hadoop.security.Groups groups,
Map<FSQueueType,Set<String>> configuredQueues) |
protected String |
QueuePlacementRule.Default.getQueueForApp(String requestedQueue,
String user,
org.apache.hadoop.security.Groups groups,
Map<FSQueueType,Set<String>> configuredQueues) |
protected String |
QueuePlacementRule.Reject.getQueueForApp(String requestedQueue,
String user,
org.apache.hadoop.security.Groups groups,
Map<FSQueueType,Set<String>> configuredQueues) |
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) |
QueuePlacementPolicy(List<QueuePlacementRule> rules,
Map<FSQueueType,Set<String>> configuredQueues,
org.apache.hadoop.conf.Configuration conf) |
Copyright © 2017 Apache Software Foundation. All Rights Reserved.