Home
last modified time | relevance | path

Searched refs:assignContainer (Results 1 – 9 of 9) 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 DFSAppAttempt.java495 private Resource assignContainer( in assignContainer() method in FSAppAttempt
556 private Resource assignContainer(FSSchedulerNode node, boolean reserved) { in assignContainer() method in FSAppAttempt
609 return assignContainer(node, localRequest, in assignContainer()
620 return assignContainer(node, rackLocalRequest, in assignContainer()
634 return assignContainer( in assignContainer()
670 return assignContainer(node, true); in assignReservedContainer()
787 public Resource assignContainer(FSSchedulerNode node) { in assignContainer() method in FSAppAttempt
788 return assignContainer(node, false); in assignContainer()
H A DSchedulable.java92 public Resource assignContainer(FSSchedulerNode node); in assignContainer() method
H A DFSParentQueue.java163 public Resource assignContainer(FSSchedulerNode node) { in assignContainer() method in FSParentQueue
173 assigned = child.assignContainer(node); in assignContainer()
H A DFSLeafQueue.java303 public Resource assignContainer(FSSchedulerNode node) { in assignContainer() method in FSLeafQueue
331 assigned = sched.assignContainer(node); in assignContainer()
H A DFairScheduler.java1096 if (!queueMgr.getRootQueue().assignContainer(node).equals( in attemptScheduling()
/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 DFakeSchedulable.java84 public Resource assignContainer(FSSchedulerNode node) { in assignContainer() method in FakeSchedulable
/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 DLeafQueue.java1295 return assignContainer(clusterResource, node, application, priority, in assignNodeLocalContainers()
1310 return assignContainer(clusterResource, node, application, priority, in assignRackLocalContainers()
1325 return assignContainer(clusterResource, node, application, priority, in assignOffSwitchContainers()
1408 private Resource assignContainer(Resource clusterResource, FiCaSchedulerNode node, in assignContainer() method in LeafQueue
1636 user.assignContainer(resource, nodeLabels); in allocateResource()
1774 public void assignContainer(Resource resource, in assignContainer() method in LeafQueue.User
/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 DFifoScheduler.java605 assignContainer(node, application, priority, in assignNodeLocalContainers()
630 assignContainer(node, application, priority, in assignRackLocalContainers()
643 assignContainer(node, application, priority, in assignOffSwitchContainers()
649 private int assignContainer(FiCaSchedulerNode node, FiCaSchedulerApp application, in assignContainer() method in FifoScheduler
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/test/java/org/apache/hadoop/mapreduce/v2/app/rm/
H A DTestRMContainerAllocator.java2507 ContainerId cid0 = mockScheduler.assignContainer("h0", false);
2519 ContainerId cid1 = mockScheduler.assignContainer("h1", false);
2520 ContainerId cid2 = mockScheduler.assignContainer("h2", false);
2521 ContainerId cid3 = mockScheduler.assignContainer("h3", false);
2537 ContainerId cid4 = mockScheduler.assignContainer("h4", false);
2552 cid0 = mockScheduler.assignContainer("h0", true);
2564 cid0 = mockScheduler.assignContainer("h0", true);
2674 public ContainerId assignContainer(String nodeName, boolean isReduce) {