org.apache.hadoop.mapred.QueueManager.getJobQueueInfos()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(2.3k)|赞(0)|评价(0)|浏览(79)

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

QueueManager.getJobQueueInfos介绍

[英]Return an array of JobQueueInfo objects for all the queues configurated in the system.
[中]为系统中配置的所有队列返回JobQueueInfo对象数组。

代码示例

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

@Override
public JobQueueInfo[] getQueues() throws IOException {
 return queueManager.getJobQueueInfos();
}

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

@Override
public JobQueueInfo[] getQueues() throws IOException {
 return queueManager.getJobQueueInfos();
}

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

@Deprecated 
public JobQueueInfo[] getJobQueues() throws IOException {
 return queueManager.getJobQueueInfos();
}

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

@Override
public QueueInfo[] getQueues() throws IOException {
 return getQueueInfoArray(queueManager.getJobQueueInfos());
}

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

for(JobQueueInfo jobInfo : manager.getJobQueueInfos()){
  queueJobQueueInfos.add(jobInfo.getQueueName());

代码示例来源: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: 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));
}

相关文章