| /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/ |
| H A D | AppSchedulingInfo.java | 73 private ActiveUsersManager activeUsersManager; field in AppSchedulingInfo
80 String user, Queue queue, ActiveUsersManager activeUsersManager, in AppSchedulingInfo() argument
87 this.activeUsersManager = activeUsersManager; in AppSchedulingInfo()
157 activeUsersManager.activateApplication(user, applicationId); in updateResourceRequests()
393 activeUsersManager.deactivateApplication(user, applicationId); in checkForDeactivation()
411 activeUsersManager.deactivateApplication(user, applicationId); in move()
412 activeUsersManager = newQueue.getActiveUsersManager(); in move()
413 activeUsersManager.activateApplication(user, applicationId); in move()
|
| H A D | SchedulerApplicationAttempt.java | 127 String user, Queue queue, ActiveUsersManager activeUsersManager, in SchedulerApplicationAttempt() argument
133 activeUsersManager, rmContext.getEpoch()); in SchedulerApplicationAttempt()
|
| /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 | FSLeafQueue.java | 71 private final ActiveUsersManager activeUsersManager; field in FSLeafQueue
78 activeUsersManager = new ActiveUsersManager(getMetrics()); in FSLeafQueue()
472 return activeUsersManager; in getActiveUsersManager()
|
| H A D | FSAppAttempt.java | 96 ActiveUsersManager activeUsersManager, RMContext rmContext) { in FSAppAttempt() argument
97 super(applicationAttemptId, user, queue, activeUsersManager, rmContext); in FSAppAttempt()
|
| /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/ |
| H A D | TestSchedulerApplicationAttempt.java | 153 ActiveUsersManager activeUsersManager = new ActiveUsersManager(metrics); in createQueue() local
156 when(queue.getActiveUsersManager()).thenReturn(activeUsersManager); in createQueue()
|
| /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/fifo/ |
| H A D | FifoScheduler.java | 117 private ActiveUsersManager activeUsersManager; field in FifoScheduler
179 return activeUsersManager;
231 this.activeUsersManager = new ActiveUsersManager(metrics); in initScheduler()
388 activeUsersManager, this.rmContext); in addApplicationAttempt()
421 activeUsersManager.deactivateApplication(application.getUser(), in doneApplication()
|
| /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/common/fica/ |
| H A D | FiCaSchedulerApp.java | 73 String user, Queue queue, ActiveUsersManager activeUsersManager, in FiCaSchedulerApp() argument
75 super(applicationAttemptId, user, queue, activeUsersManager, rmContext); in FiCaSchedulerApp()
|
| /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/capacity/ |
| H A D | TestApplicationLimits.java | 175 ActiveUsersManager activeUsersManager = mock(ActiveUsersManager.class); in testAMResourceLimit() local
176 when(queue.getActiveUsersManager()).thenReturn(activeUsersManager); in testAMResourceLimit()
192 when(activeUsersManager.getNumActiveUsers()).thenReturn(1); in testAMResourceLimit()
216 when(activeUsersManager.getNumActiveUsers()).thenReturn(2); in testAMResourceLimit()
|
| /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/capacity/ |
| H A D | LeafQueue.java | 112 private final ActiveUsersManager activeUsersManager; field in LeafQueue
130 this.activeUsersManager = new ActiveUsersManager(metrics); in LeafQueue()
292 return activeUsersManager; in getActiveUsersManager()
674 activeUsersManager.deactivateApplication(user, application); in finishApplication()
1038 final int activeUsers = activeUsersManager.getNumActiveUsers(); in computeUserLimit()
|