| /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 | TestParentQueue.java | 234 root.assignContainers(clusterResource, node_0, in testSingleLevelQueues()
242 root.assignContainers(clusterResource, node_1, in testSingleLevelQueues()
256 root.assignContainers(clusterResource, node_0, in testSingleLevelQueues()
270 root.assignContainers(clusterResource, node_0, in testSingleLevelQueues()
284 root.assignContainers(clusterResource, node_1, in testSingleLevelQueues()
467 root.assignContainers(clusterResource, node_0, in testMultiLevelQueues()
480 root.assignContainers(clusterResource, node_1, in testMultiLevelQueues()
492 root.assignContainers(clusterResource, node_0, in testMultiLevelQueues()
519 root.assignContainers(clusterResource, node_2, in testMultiLevelQueues()
629 root.assignContainers(clusterResource, node_0, in testOffSwitchScheduling()
[all …]
|
| H A D | TestLeafQueue.java | 494 a.assignContainers(clusterResource, node_0, in testSingleQueueWithOneUser()
505 a.assignContainers(clusterResource, node_0, in testSingleQueueWithOneUser()
514 a.assignContainers(clusterResource, node_0, in testSingleQueueWithOneUser()
524 a.assignContainers(clusterResource, node_0, in testSingleQueueWithOneUser()
533 a.assignContainers(clusterResource, node_0, in testSingleQueueWithOneUser()
660 a.assignContainers(clusterResource, node_0, in testUserLimits()
667 a.assignContainers(clusterResource, node_0, in testUserLimits()
674 a.assignContainers(clusterResource, node_1, in testUserLimits()
883 a.assignContainers(clusterResource, node_0, in testUserHeadroomMultiApp()
900 a.assignContainers(clusterResource, node_0, in testUserHeadroomMultiApp()
[all …]
|
| H A D | TestChildQueueOrder.java | 147 .assignContainers(eq(clusterResource), eq(node), in stubQueueAllocation()
159 when(queue).assignContainers(eq(clusterResource), eq(node), in stubQueueAllocation()
277 root.assignContainers(clusterResource, node_0, new ResourceLimits( in testSortedQueues()
285 root.assignContainers(clusterResource, node_0, new ResourceLimits( in testSortedQueues()
294 root.assignContainers(clusterResource, node_0, new ResourceLimits( in testSortedQueues()
303 root.assignContainers(clusterResource, node_0, new ResourceLimits( in testSortedQueues()
365 root.assignContainers(clusterResource, node_0, new ResourceLimits( in testSortedQueues()
392 root.assignContainers(clusterResource, node_0, new ResourceLimits( in testSortedQueues()
407 root.assignContainers(clusterResource, node_0, new ResourceLimits( in testSortedQueues()
410 allocationOrder.verify(d).assignContainers(eq(clusterResource), in testSortedQueues()
[all …]
|
| H A D | TestReservations.java | 270 a.assignContainers(clusterResource, node_0, in testReservation()
282 a.assignContainers(clusterResource, node_0, in testReservation()
294 a.assignContainers(clusterResource, node_1, in testReservation()
309 a.assignContainers(clusterResource, node_0, in testReservation()
325 a.assignContainers(clusterResource, node_2, in testReservation()
342 a.assignContainers(clusterResource, node_1, in testReservation()
426 a.assignContainers(clusterResource, node_0, in testReservationNoContinueLook()
438 a.assignContainers(clusterResource, node_0, in testReservationNoContinueLook()
450 a.assignContainers(clusterResource, node_1, in testReservationNoContinueLook()
465 a.assignContainers(clusterResource, node_0, in testReservationNoContinueLook()
[all …]
|
| H A D | TestApplicationLimits.java | 614 queue.assignContainers(clusterResource, node_0, new ResourceLimits( in testHeadroom()
634 queue.assignContainers(clusterResource, node_0, new ResourceLimits( in testHeadroom()
654 queue.assignContainers(clusterResource, node_0, new ResourceLimits( in testHeadroom()
663 queue.assignContainers(clusterResource, node_0, new ResourceLimits( in testHeadroom()
|
| /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 | CSQueue.java | 195 public CSAssignment assignContainers(Resource clusterResource, in assignContainers() method
|
| H A D | ParentQueue.java | 378 public synchronized CSAssignment assignContainers(Resource clusterResource, in assignContainers() method in ParentQueue
510 assignment = childQueue.assignContainers(cluster, node, childLimits); in assignContainersToChildQueues()
|
| H A D | CapacityScheduler.java | 1132 queue.assignContainers( in allocateContainersToNode()
1162 root.assignContainers( in allocateContainersToNode()
|
| H A D | LeafQueue.java | 744 public synchronized CSAssignment assignContainers(Resource clusterResource, in assignContainers() method in LeafQueue
|
| /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 | 463 private void assignContainers(FiCaSchedulerNode node) { in assignContainers() method in FifoScheduler
734 assignContainers(node); in nodeUpdate()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/rm/ |
| H A D | RMContainerAllocator.java | 1068 assignContainers(allocatedContainers); in assign()
1121 private void assignContainers(List<Container> allocatedContainers) { in assignContainers() method in RMContainerAllocator.ScheduledRequests
|