import org.apache.hadoop.yarn.server.resourcemanager.resource.Priority; //导入依赖的package包/类
RMContainer mockContainer(ApplicationAttemptId appAttId, int id,
    Resource r, int cpriority) {
  ContainerId cId = ContainerId.newContainerId(appAttId, id);
  Container c = mock(Container.class);
  when(c.getResource()).thenReturn(r);
  when(c.getPriority()).thenReturn(Priority.create(cpriority));
  RMContainer mC = mock(RMContainer.class);
  when(mC.getContainerId()).thenReturn(cId);
  when(mC.getContainer()).thenReturn(c);
  when(mC.getApplicationAttemptId()).thenReturn(appAttId);
  if (priority.AMCONTAINER.getValue() == cpriority) {
    when(mC.isAMContainer()).thenReturn(true);
  }
  if (priority.LABELEDCONTAINER.getValue() == cpriority) {
    when(mC.getAllocatedNode()).thenReturn(NodeId.newInstance("node1", 0));
  }
  return mC;
}
 

import org.apache.hadoop.yarn.server.resourcemanager.resource.Priority; //导入依赖的package包/类
RMContainer mockContainer(ApplicationAttemptId appAttId, int id,
    Resource r, int cpriority) {
  ContainerId cId = ContainerId.newContainerId(appAttId, id);
  Container c = mock(Container.class);
  when(c.getResource()).thenReturn(r);
  when(c.getPriority()).thenReturn(Priority.create(cpriority));
  RMContainer mC = mock(RMContainer.class);
  when(mC.getContainerId()).thenReturn(cId);
  when(mC.getContainer()).thenReturn(c);
  when(mC.getApplicationAttemptId()).thenReturn(appAttId);
  when(mC.getAllocatedResource()).thenReturn(r);
  if (priority.AMCONTAINER.getValue() == cpriority) {
    when(mC.isAMContainer()).thenReturn(true);
  }
  if (priority.LABELEDCONTAINER.getValue() == cpriority) {
    when(mC.getAllocatedNode()).thenReturn(NodeId.newInstance("node1", 0));
  }
  return mC;
}
 

import org.apache.hadoop.yarn.server.resourcemanager.resource.Priority; //导入依赖的package包/类
@Override
public void addNewContainer(String containerId, String nodeId,
        String httpAddress,
        int memory, int vcores, int priority, long lifeTimeMS) throws
        RemoteException {
  Container container
          = BuilderUtils.newContainer(ConverterUtils.
                  toContainerId(containerId),
                  ConverterUtils.toNodeId(nodeId), httpAddress,
                  Resources.createResource(memory, vcores),
                  Priority.create(priority), null);

  // this we can move to thread queue to increase the performance, so we don't need to wait
  nmMap.get(container.getNodeId())
          .addNewContainer(container, lifeTimeMS);
}
 

import org.apache.hadoop.yarn.server.resourcemanager.resource.Priority; //导入依赖的package包/类
RMContainer mockContainer(ApplicationAttemptId appAttId, int id,
    Resource r, int priority) {
  ContainerId cId = ContainerId.newContainerId(appAttId, id);
  Container c = mock(Container.class);
  when(c.getResource()).thenReturn(r);
  when(c.getPriority()).thenReturn(Priority.create(priority));
  RMContainer mC = mock(RMContainer.class);
  when(mC.getContainerId()).thenReturn(cId);
  when(mC.getContainer()).thenReturn(c);
  when(mC.getApplicationAttemptId()).thenReturn(appAttId);
  if(0 == priority){
    when(mC.isAMContainer()).thenReturn(true);
  }
  return mC;
}
 

import org.apache.hadoop.yarn.server.resourcemanager.resource.Priority; //导入依赖的package包/类
RMContainer mockContainer(ApplicationAttemptId appAttId, int id,
    Resource r, int priority) {
  ContainerId cId = ContainerId.newInstance(appAttId, id);
  Container c = mock(Container.class);
  when(c.getResource()).thenReturn(r);
  when(c.getPriority()).thenReturn(Priority.create(priority));
  RMContainer mC = mock(RMContainer.class);
  when(mC.getContainerId()).thenReturn(cId);
  when(mC.getContainer()).thenReturn(c);
  return mC;
}