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

QueueManager.setSchedulerInfo介绍

[英]Set a generic Object that represents scheduling information relevant to a queue.

A string representation of this Object will be used by the framework to display in user facing applications like the JobTracker web UI and the hadoop CLI.
[中]设置表示与队列相关的调度信息的通用对象。
框架将使用该对象的字符串表示，在面向用户的应用程序中显示，如JobTracker web UI和hadoop CLI。

代码示例

代码示例来源：origin: org.apache.hadoop/hadoop-mapreduce-client-core

manager.setSchedulerInfo("first", "queueInfo");
manager.setSchedulerInfo("second", "queueInfoqueueInfo");

代码示例来源：origin: org.apache.hadoop/hadoop-mapreduce-client-core

manager.setSchedulerInfo("first", "queueInfo");
manager.setSchedulerInfo("second", "queueInfoqueueInfo");
Queue root = manager.getRoot();
assertTrue(root.getChildren().size() == 2);

代码示例来源：origin: org.apache.hadoop/hadoop-mapred-test

public void testSchedulerInfo() {
 JobConf conf = new JobConf();
 conf.set(DeprecatedQueueConfigurationParser.MAPRED_QUEUE_NAMES_KEY,
   "qq1,qq2");
 QueueManager qMgr = new QueueManager(conf);
 qMgr.setSchedulerInfo("qq1", "queueInfoForqq1");
 qMgr.setSchedulerInfo("qq2", "queueInfoForqq2");
 assertEquals(qMgr.getSchedulerInfo("qq2"), "queueInfoForqq2");
 assertEquals(qMgr.getSchedulerInfo("qq1"), "queueInfoForqq1");
}

代码示例来源：origin: com.facebook.hadoop/hadoop-core

@Override
public synchronized void start() throws IOException {
 super.start();
 QueueManager queueManager = taskTrackerManager.getQueueManager();
 String queueName = queueManager.getJobQueueInfos()[0].getQueueName();
 queueManager.setSchedulerInfo(queueName
   ,"Maximum Tasks Per Job :: " + String.valueOf(maxTasksPerJob));
}

代码示例来源：origin: org.apache.hadoop/hadoop-mapred

@Override
public synchronized void start() throws IOException {
 super.start();
 QueueManager queueManager = taskTrackerManager.getQueueManager();
 String queueName = queueManager.getJobQueueInfos()[0].getQueueName();
 queueManager.setSchedulerInfo(queueName
   ,"Maximum Tasks Per Job :: " + String.valueOf(maxTasksPerJob));
}

代码示例来源：origin: org.jvnet.hudson.hadoop/hadoop-core

@Override
public synchronized void start() throws IOException {
 super.start();
 QueueManager queueManager = taskTrackerManager.getQueueManager();
 String queueName = queueManager.getJobQueueInfos()[0].getQueueName();
 queueManager.setSchedulerInfo(queueName
   ,"Maximum Tasks Per Job :: " + String.valueOf(maxTasksPerJob));
}

代码示例来源：origin: org.apache.hadoop/hadoop-mapred-test

/**
 * Test to verify that the scheduling information per queue in the
 * {@link QueueManager} is retained across queue-refresh.
 * 
 * @throws Exception
 */
@Test
public void testSchedulingInfoAfterRefresh()
  throws Exception {
 JobQueueInfo[] queues = getSimpleQueueHierarchy();
 // write the configuration file
 writeQueueConfigurationFile(
   QUEUES_CONFIG_FILE_PATH, new JobQueueInfo[] { queues[0] });
 QueueManager qManager = new QueueManager();
 // Set some scheduling information for the queues in the QueueManager.
 for (String qName : qManager.getLeafQueueNames()) {
  qManager.setSchedulerInfo(qName, new String(
    "scheduling-information-for-queue-" + qName));
 }
 qManager.refreshQueues(null, null);
 // Verify that the scheduling information is retained across refresh.
 for (String qName : qManager.getLeafQueueNames()) {
  assertEquals("scheduling-information-for-queue-" + qName,
    qManager.getSchedulerInfo(qName));
 }
}