本文整理了Java中org.apache.hadoop.mapred.QueueManager.getSchedulerInfo
方法的一些代码示例,展示了QueueManager.getSchedulerInfo
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueueManager.getSchedulerInfo
方法的具体详情如下:
包路径:org.apache.hadoop.mapred.QueueManager
类名称:QueueManager
方法名:getSchedulerInfo
[英]Return the scheduler information configured for this queue.
[中]返回为此队列配置的计划程序信息。
代码示例来源:origin: org.apache.hadoop/hadoop-mapreduce-client-core
assertEquals(secondSubQueue.getJobQueueInfo().getChildren().size(), 0);
assertEquals(manager.getSchedulerInfo("first"), "queueInfo");
Set<String> queueJobQueueInfos = new HashSet<String>();
for(JobQueueInfo jobInfo : manager.getJobQueueInfos()){
代码示例来源: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: 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));
}
}
内容来源于网络,如有侵权,请联系作者删除!