| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/ |
| H A D | QueuePlacementRule.java | 72 Groups groups, Map<FSQueueType, Set<String>> configuredQueues) in assignAppToQueue() argument
75 configuredQueues); in assignAppToQueue()
76 if (create || configuredQueues.get(FSQueueType.LEAF).contains(queue) in assignAppToQueue()
77 || configuredQueues.get(FSQueueType.PARENT).contains(queue)) { in assignAppToQueue()
122 Groups groups, Map<FSQueueType, Set<String>> configuredQueues) in getQueueForApp() argument
131 Groups groups, Map<FSQueueType, Set<String>> configuredQueues) { in getQueueForApp() argument
147 Groups groups, Map<FSQueueType, Set<String>> configuredQueues) in getQueueForApp() argument
167 Groups groups, Map<FSQueueType, Set<String>> configuredQueues) in getQueueForApp() argument
173 || configuredQueues.get(FSQueueType.PARENT).contains( in getQueueForApp()
232 Groups groups, Map<FSQueueType, Set<String>> configuredQueues) in getQueueForApp() argument
[all …]
|
| H A D | QueuePlacementPolicy.java | 57 private final Map<FSQueueType, Set<String>> configuredQueues; field in QueuePlacementPolicy
61 Map<FSQueueType, Set<String>> configuredQueues, Configuration conf) in QueuePlacementPolicy() argument
74 this.configuredQueues = configuredQueues; in QueuePlacementPolicy()
82 Map<FSQueueType, Set<String>> configuredQueues, Configuration conf) in fromXml() argument
93 return new QueuePlacementPolicy(rules, configuredQueues, conf); in fromXml()
127 Map<FSQueueType, Set<String>> configuredQueues) { in fromConfiguration() argument
143 return new QueuePlacementPolicy(rules, configuredQueues, conf); in fromConfiguration()
168 configuredQueues); in assignAppToQueue()
|
| H A D | AllocationConfiguration.java | 92 Map<FSQueueType, Set<String>> configuredQueues; field in AllocationConfiguration
110 Map<FSQueueType, Set<String>> configuredQueues, in AllocationConfiguration() argument
131 this.configuredQueues = configuredQueues; in AllocationConfiguration()
151 configuredQueues = new HashMap<FSQueueType, Set<String>>(); in AllocationConfiguration()
153 configuredQueues.put(queueType, new HashSet<String>()); in AllocationConfiguration()
156 configuredQueues); in AllocationConfiguration()
274 return configuredQueues; in getConfiguredQueues()
|
| H A D | AllocationFileLoaderService.java | 245 Map<FSQueueType, Set<String>> configuredQueues = in reloadAllocations() local
248 configuredQueues.put(queueType, new HashSet<String>()); in reloadAllocations()
355 fairSharePreemptionThresholds, queueAcls, configuredQueues, in reloadAllocations()
363 configuredQueues, conf); in reloadAllocations()
366 configuredQueues); in reloadAllocations()
426 Map<FSQueueType, Set<String>> configuredQueues, in loadQueue() argument
497 configuredQueues.get(FSQueueType.PARENT).add(queueName); in loadQueue()
504 queueAcls, configuredQueues, reservableQueues); in loadQueue()
512 configuredQueues.get(FSQueueType.PARENT).add(queueName); in loadQueue()
514 configuredQueues.get(FSQueueType.LEAF).add(queueName); in loadQueue()
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/ |
| H A D | TestQueuePlacementPolicy.java | 42 private Map<FSQueueType, Set<String>> configuredQueues; field in TestQueuePlacementPolicy
52 configuredQueues = new HashMap<FSQueueType, Set<String>>(); in initTest()
54 configuredQueues.put(type, new HashSet<String>()); in initTest()
83 configuredQueues.get(FSQueueType.LEAF).add("root.someuser"); in testNoCreate()
226 configuredQueues.get(FSQueueType.LEAF).add("root.specifiedq"); in testNestedUserQueuePrimaryGroup()
232 configuredQueues.get(FSQueueType.LEAF).add("root.user3group"); in testNestedUserQueuePrimaryGroup()
256 configuredQueues.get(FSQueueType.PARENT).add("root.user1group"); in testNestedUserQueuePrimaryGroupNoCreate()
276 configuredQueues.get(FSQueueType.PARENT).add("root.user2group"); in testNestedUserQueuePrimaryGroupNoCreate()
320 configuredQueues.get(FSQueueType.PARENT).add("root.parent1"); in testNestedUserQueueSpecificRule()
321 configuredQueues.get(FSQueueType.PARENT).add("root.parent2"); in testNestedUserQueueSpecificRule()
[all …]
|
| H A D | TestQueueManager.java | 99 allocConf.configuredQueues.get(FSQueueType.LEAF).add("root.queue1"); in testReloadTurnsLeafToParentWithNoLeaf()
108 allocConf.configuredQueues.get(FSQueueType.PARENT) in testReloadTurnsLeafToParentWithNoLeaf()
129 allocConf.configuredQueues.get(FSQueueType.LEAF).addAll(Sets.newHashSet(confLeafQueues)); in updateConfiguredLeafQueues()
|
| H A D | TestFairScheduler.java | 1092 Map<FSQueueType, Set<String>> configuredQueues = new HashMap<FSQueueType, Set<String>>(); in testQueuePlacementWithPolicy() local
1093 configuredQueues.put(FSQueueType.LEAF, queues); in testQueuePlacementWithPolicy()
1094 configuredQueues.put(FSQueueType.PARENT, new HashSet<String>()); in testQueuePlacementWithPolicy()
1096 new QueuePlacementPolicy(rules, configuredQueues, conf); in testQueuePlacementWithPolicy()
1116 new QueuePlacementPolicy(rules, configuredQueues, conf); in testQueuePlacementWithPolicy()
|