/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 | QueueManager.java | 56 private final Map<String, FSQueue> queues = new HashMap<String, FSQueue>(); 128 FSQueue queue = queues.get(name); in getQueue() 159 FSQueue queue; in createQueue() 238 FSQueue queue = queues.get(queueToCreate); in removeEmptyIncompatibleQueues() 265 FSQueue prefixQueue = queues.get(prefixString); in removeEmptyIncompatibleQueues() 290 private void removeQueue(FSQueue queue) { in removeQueue() 307 protected boolean isEmpty(FSQueue queue) { in isEmpty() 313 for (FSQueue child : queue.getChildQueues()) { in isEmpty() 325 public FSQueue getQueue(String name) { in getQueue() 354 public Collection<FSQueue> getQueues() { in getQueues() [all …]
|
H A D | FSParentQueue.java | 43 public class FSParentQueue extends FSQueue { 47 private final List<FSQueue> childQueues = 48 new ArrayList<FSQueue>(); 57 public void addChildQueue(FSQueue child) { in addChildQueue() 64 for (FSQueue childQueue : childQueues) { in recomputeShares() 97 for (FSQueue child : childQueues) { in getResourceUsage() 155 for (FSQueue child : childQueues) { in getQueueUserAclInfo() 172 for (FSQueue child : childQueues) { in assignContainer() 186 FSQueue candidateQueue = null; in preemptContainer() 188 for (FSQueue queue : childQueues) { in preemptContainer() [all …]
|
H A D | FSQueue.java | 43 public abstract class FSQueue implements Queue, Schedulable { class 60 public FSQueue(String name, FairScheduler scheduler, FSParentQueue parent) { in FSQueue() method in FSQueue 143 Collection<FSQueue> childQueues = getChildQueues(); in getQueueInfo() 144 for (FSQueue child : childQueues) { in getQueueInfo() 240 public abstract List<FSQueue> getChildQueues(); in getChildQueues()
|
H A D | MaxRunningAppsEnforcer.java | 58 public boolean canAppBeRunnable(FSQueue queue, String user) { in canAppBeRunnable() 145 FSQueue highestQueueWithAppsNowRunnable = (queue.getNumRunnableApps() == in updateRunnabilityOnAppRemoval() 266 private void gatherPossiblyRunnableAppLists(FSQueue queue, in gatherPossiblyRunnableAppLists() 274 for (FSQueue child : queue.getChildQueues()) { in gatherPossiblyRunnableAppLists()
|
H A D | FairScheduler.java | 304 FSQueue rootQueue = queueMgr.getRootQueue(); in update() 1070 FSQueue queue = reservedAppSchedulable.getQueue(); in attemptScheduling() 1109 static boolean fitsInMaxShare(FSQueue queue, Resource in fitsInMaxShare() 1118 FSQueue parentQueue = queue.getParent(); in fitsInMaxShare() 1275 FSQueue queue = queueMgr.getQueue(queueName); in resolveReservationQueueName() 1486 FSQueue queue = getQueueManager().getQueue(queueName); in checkAccess() 1519 FSQueue queue = queueMgr.getQueue(queueName); in getAppsInQueue() 1570 FSQueue cur = targetQueue; in verifyMoveDoesNotViolateConstraints() 1626 FSQueue findLowestCommonAncestorQueue(FSQueue queue1, FSQueue queue2) { in findLowestCommonAncestorQueue() 1668 for (FSQueue fsQueue : queueMgr.getQueues()) { in getPlanQueues() [all …]
|
H A D | FSLeafQueue.java | 49 public class FSLeafQueue extends FSQueue { 379 public List<FSQueue> getChildQueues() { in getChildQueues() 380 return new ArrayList<FSQueue>(1); in getChildQueues()
|
H A D | SchedulingPolicy.java | 157 Collection<? extends FSQueue> queues, Resource totalResources); in computeSteadyShares()
|
H A D | FSAppAttempt.java | 180 final FSQueue queue = (FSQueue) this.queue; in getHeadroom()
|
/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/policies/ |
H A D | ComputeFairShares.java | 25 import org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.FSQueue; 64 Collection<? extends FSQueue> queues, Resource totalResources, in computeSteadyShares() 164 ((FSQueue) sched).getSteadyFairShare(), type); in computeSharesInternal() 216 ? ((FSQueue)sched).getSteadyFairShare() in handleFixedFairShares() 242 (sched instanceof FSQueue) && !((FSQueue)sched).isActive()) { in getFairShareIfFixed()
|
H A D | FifoPolicy.java | 27 import org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.FSQueue; 92 public void computeSteadyShares(Collection<? extends FSQueue> queues, in computeSteadyShares()
|
H A D | FairSharePolicy.java | 28 import org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.FSQueue; 135 public void computeSteadyShares(Collection<? extends FSQueue> queues, in computeSteadyShares()
|
H A D | DominantResourceFairnessPolicy.java | 29 import org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.FSQueue; 74 public void computeSteadyShares(Collection<? extends FSQueue> queues, in computeSteadyShares()
|
/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/webapp/dao/ |
H A D | FairSchedulerQueueInfo.java | 33 import org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.FSQueue; 69 public FairSchedulerQueueInfo(FSQueue queue, FairScheduler scheduler) { in FairSchedulerQueueInfo() 104 Collection<FSQueue> children = queue.getChildQueues(); in FairSchedulerQueueInfo() 105 for (FSQueue child : children) { in FairSchedulerQueueInfo()
|
/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/reservation/ |
H A D | FairSchedulerPlanFollower.java | 30 import org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.FSQueue; 78 FSQueue planQueue = (FSQueue)queue; in getChildReservationQueues() 79 List<FSQueue> childQueues = planQueue.getChildQueues(); in getChildReservationQueues()
|
/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 | TestQueueManager.java | 35 private Set<FSQueue> notEmptyQueues; 46 notEmptyQueues = new HashSet<FSQueue>(); in setUp() 49 public boolean isEmpty(FSQueue queue) { in setUp()
|
H A D | TestFairScheduler.java | 1536 FSQueue root = queueManager.getRootQueue(); in testConfigureRootQueue() 4443 FSQueue ancestorQueue = in testLowestCommonAncestorForNonRootParent() 4464 FSQueue ancestorQueue = in testLowestCommonAncestorRootParent() 4475 FSQueue aQueue = mock(FSLeafQueue.class); in testLowestCommonAncestorDeeperHierarchy() 4476 FSQueue bQueue = mock(FSLeafQueue.class); in testLowestCommonAncestorDeeperHierarchy() 4477 FSQueue a1Queue = mock(FSLeafQueue.class); in testLowestCommonAncestorDeeperHierarchy() 4478 FSQueue b1Queue = mock(FSLeafQueue.class); in testLowestCommonAncestorDeeperHierarchy() 4489 FSQueue ancestorQueue = in testLowestCommonAncestorDeeperHierarchy()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/scheduler/ |
H A D | FairSchedulerMetrics.java | 26 import org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.FSQueue; 155 final FSQueue queue = fair.getQueueManager().getQueue(queueName); in trackQueue()
|
/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/reservation/ |
H A D | TestFairSchedulerPlanFollower.java | 47 import org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.FSQueue; 137 assertTrue(((FSQueue) defQ).getWeights().getWeight(ResourceType.MEMORY) > in verifyCapacity()
|