Home
last modified time | relevance | path

Searched refs:FSQueue (Results 1 – 18 of 18) sorted by relevance

/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 DQueueManager.java56 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 DFSParentQueue.java43 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 DFSQueue.java43 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 DMaxRunningAppsEnforcer.java58 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 DFairScheduler.java304 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 DFSLeafQueue.java49 public class FSLeafQueue extends FSQueue {
379 public List<FSQueue> getChildQueues() { in getChildQueues()
380 return new ArrayList<FSQueue>(1); in getChildQueues()
H A DSchedulingPolicy.java157 Collection<? extends FSQueue> queues, Resource totalResources); in computeSteadyShares()
H A DFSAppAttempt.java180 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 DComputeFairShares.java25 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 DFifoPolicy.java27 import org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.FSQueue;
92 public void computeSteadyShares(Collection<? extends FSQueue> queues, in computeSteadyShares()
H A DFairSharePolicy.java28 import org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.FSQueue;
135 public void computeSteadyShares(Collection<? extends FSQueue> queues, in computeSteadyShares()
H A DDominantResourceFairnessPolicy.java29 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 DFairSchedulerQueueInfo.java33 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 DFairSchedulerPlanFollower.java30 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 DTestQueueManager.java35 private Set<FSQueue> notEmptyQueues;
46 notEmptyQueues = new HashSet<FSQueue>(); in setUp()
49 public boolean isEmpty(FSQueue queue) { in setUp()
H A DTestFairScheduler.java1536 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 DFairSchedulerMetrics.java26 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 DTestFairSchedulerPlanFollower.java47 import org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.FSQueue;
137 assertTrue(((FSQueue) defQ).getWeights().getWeight(ResourceType.MEMORY) > in verifyCapacity()