本文整理了Java中org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.QueueManager.<init>方法的一些代码示例，展示了QueueManager.<init>的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。QueueManager.<init>方法的具体详情如下：
包路径：org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.QueueManager
类名称：QueueManager
方法名：<init>

QueueManager.<init>介绍

暂无

代码示例

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

public FairScheduler() {
 super(FairScheduler.class.getName());
 clock = new SystemClock();
 allocsLoader = new AllocationFileLoaderService();
 queueMgr = new QueueManager(this);
 maxRunningEnforcer = new MaxRunningAppsEnforcer(this);
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

public FairScheduler() {
 super(FairScheduler.class.getName());
 context = new FSContext(this);
 allocsLoader = new AllocationFileLoaderService();
 queueMgr = new QueueManager(this);
 maxRunningEnforcer = new MaxRunningAppsEnforcer(this);
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-server-resourcemanager

public FairScheduler() {
 super(FairScheduler.class.getName());
 clock = new SystemClock();
 allocsLoader = new AllocationFileLoaderService();
 queueMgr = new QueueManager(this);
 maxRunningEnforcer = new MaxRunningAppsEnforcer(this);
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

@Before
public void setup() throws Exception {
 Configuration conf = new Configuration();
 clock = new TestFairScheduler.MockClock();
 scheduler = mock(FairScheduler.class);
 when(scheduler.getConf()).thenReturn(
   new FairSchedulerConfiguration(conf));
 when(scheduler.getClock()).thenReturn(clock);
 AllocationConfiguration allocConf = new AllocationConfiguration(
   conf);
 when(scheduler.getAllocationConfiguration()).thenReturn(allocConf);
 
 queueManager = new QueueManager(scheduler);
 queueManager.initialize(conf);
 queueMaxApps = allocConf.queueMaxApps;
 userMaxApps = allocConf.userMaxApps;
 maxAppsEnforcer = new MaxRunningAppsEnforcer(scheduler);
 appNum = 0;
 rmContext = mock(RMContext.class);
 when(rmContext.getEpoch()).thenReturn(0L);
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

@Before
public void setUp() throws Exception {
 conf = new FairSchedulerConfiguration();
 scheduler = mock(FairScheduler.class);
 AllocationConfiguration allocConf = new AllocationConfiguration(conf);
 // Set up some queues to test default child max resource inheritance
 allocConf.configuredQueues.get(FSQueueType.PARENT).add("root.test");
 allocConf.configuredQueues.get(FSQueueType.LEAF).add("root.test.childA");
 allocConf.configuredQueues.get(FSQueueType.PARENT).add("root.test.childB");
 when(scheduler.getAllocationConfiguration()).thenReturn(allocConf);
 when(scheduler.getConf()).thenReturn(conf);
 when(scheduler.getResourceCalculator()).thenReturn(
   new DefaultResourceCalculator());
 SystemClock clock = SystemClock.getInstance();
 when(scheduler.getClock()).thenReturn(clock);
 notEmptyQueues = new HashSet<>();
 queueManager = new QueueManager(scheduler) {
  @Override
  public boolean isEmpty(FSQueue queue) {
   return !notEmptyQueues.contains(queue);
  }
 };
 FSQueueMetrics.forQueue("root", null, true, conf);
 queueManager.initialize(conf);
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

@Before
public void setup() throws Exception {
 Configuration conf = new Configuration();
 clock = new ControlledClock();
 scheduler = mock(FairScheduler.class);
 when(scheduler.getConf()).thenReturn(
   new FairSchedulerConfiguration(conf));
 when(scheduler.getClock()).thenReturn(clock);
 AllocationConfiguration allocConf = new AllocationConfiguration(
   conf);
 when(scheduler.getAllocationConfiguration()).thenReturn(allocConf);
 when(scheduler.getResourceCalculator()).thenReturn(
   new DefaultResourceCalculator());
 queueManager = new QueueManager(scheduler);
 queueManager.initialize(conf);
 userMaxApps = allocConf.userMaxApps;
 maxAppsEnforcer = new MaxRunningAppsEnforcer(scheduler);
 appNum = 0;
 rmContext = mock(RMContext.class);
 when(rmContext.getEpoch()).thenReturn(0L);
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

@Test
 public void testEmptyChildQueues() throws Exception {
  FairSchedulerConfiguration conf = new FairSchedulerConfiguration();
  FairScheduler scheduler = mock(FairScheduler.class);
  AllocationConfiguration allocConf = new AllocationConfiguration(conf);
  when(scheduler.getAllocationConfiguration()).thenReturn(allocConf);
  when(scheduler.getConf()).thenReturn(conf);
  when(scheduler.getClusterResource()).thenReturn(Resource.newInstance(1, 1));
  when(scheduler.getResourceCalculator()).thenReturn(
    new DefaultResourceCalculator());
  SystemClock clock = SystemClock.getInstance();
  when(scheduler.getClock()).thenReturn(clock);
  QueueManager queueManager = new QueueManager(scheduler);
  queueManager.initialize(conf);

  FSQueue testQueue = queueManager.getLeafQueue("test", true);
  FairSchedulerQueueInfo queueInfo =
    new FairSchedulerQueueInfo(testQueue, scheduler);
  Collection<FairSchedulerQueueInfo> childQueues =
    queueInfo.getChildQueues();
  Assert.assertNotNull(childQueues);
  Assert.assertEquals("Child QueueInfo was not empty", 0, childQueues.size());
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

throws Exception {
AllocationConfiguration allocConf = scheduler.getAllocationConfiguration();
queueManager = new QueueManager(scheduler);
queueManager.initialize(conf);
queueManager.updateAllocationConfiguration(allocConf);