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

QueueManager.getJobQueueInfo介绍

[英]Return JobQueueInfo for a given queue.
[中]返回给定队列的JobQueueInfo。

代码示例

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

@Override
public JobQueueInfo getQueueInfo(String queue) throws IOException {
 return queueManager.getJobQueueInfo(queue);
}

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

@Override
public JobQueueInfo getQueueInfo(String queue) throws IOException {
 return queueManager.getJobQueueInfo(queue);
}

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

@Deprecated 
public JobQueueInfo getQueueInfo(String queue) throws IOException {
 return queueManager.getJobQueueInfo(queue);
}

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

/**
 * Return an array of {@link JobQueueInfo} objects for all the
 * queues configurated in the system.
 *
 * @return array of JobQueueInfo objects.
 */
synchronized JobQueueInfo[] getJobQueueInfos() {
 ArrayList<JobQueueInfo> queueInfoList = new ArrayList<JobQueueInfo>();
 for (String queue : allQueues.keySet()) {
  JobQueueInfo queueInfo = getJobQueueInfo(queue);
  if (queueInfo != null) {
   queueInfoList.add(queueInfo);
  }
 }
 return queueInfoList.toArray(
  new JobQueueInfo[queueInfoList.size()]);
}

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

/**
 * Return an array of {@link JobQueueInfo} objects for all the
 * queues configurated in the system.
 *
 * @return array of JobQueueInfo objects.
 */
synchronized JobQueueInfo[] getJobQueueInfos() {
 ArrayList<JobQueueInfo> queueInfoList = new ArrayList<JobQueueInfo>();
 for (String queue : allQueues.keySet()) {
  JobQueueInfo queueInfo = getJobQueueInfo(queue);
  if (queueInfo != null) {
   queueInfoList.add(queueInfo);
  }
 }
 return queueInfoList.toArray(
  new JobQueueInfo[queueInfoList.size()]);
}

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

/**
 * Return an array of {@link JobQueueInfo} objects for all the
 * queues configurated in the system.
 *
 * @return array of JobQueueInfo objects.
 */
synchronized JobQueueInfo[] getJobQueueInfos() {
 ArrayList<JobQueueInfo> queueInfoList = new ArrayList<JobQueueInfo>();
 for (String queue : allQueues.keySet()) {
  JobQueueInfo queueInfo = getJobQueueInfo(queue);
  if (queueInfo != null) {
   queueInfoList.add(queueInfo);
  }
 }
 return queueInfoList.toArray(
  new JobQueueInfo[queueInfoList.size()]);
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-mapreduce-client-core

/**
 * Return an array of {@link JobQueueInfo} objects for all the
 * queues configurated in the system.
 *
 * @return array of JobQueueInfo objects.
 */
synchronized JobQueueInfo[] getJobQueueInfos() {
 ArrayList<JobQueueInfo> queueInfoList = new ArrayList<JobQueueInfo>();
 for (String queue : allQueues.keySet()) {
  JobQueueInfo queueInfo = getJobQueueInfo(queue);
  if (queueInfo != null) {
   queueInfoList.add(queueInfo);
  }
 }
 return queueInfoList.toArray(
  new JobQueueInfo[queueInfoList.size()]);
}

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

/**
 * Return an array of {@link JobQueueInfo} objects for all the
 * queues configurated in the system.
 *
 * @return array of JobQueueInfo objects.
 */
synchronized JobQueueInfo[] getJobQueueInfos() {
 ArrayList<JobQueueInfo> queueInfoList = new ArrayList<JobQueueInfo>();
 for (String queue : allQueues.keySet()) {
  JobQueueInfo queueInfo = getJobQueueInfo(queue);
  if (queueInfo != null) {
   queueInfoList.add(queueInfo);
  }
 }
 return queueInfoList.toArray(
  new JobQueueInfo[queueInfoList.size()]);
}

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

@Override
public QueueInfo getQueue(String queue) throws IOException {
 JobQueueInfo jqueue = queueManager.getJobQueueInfo(queue);
 if (jqueue != null) {
  jqueue.setJobStatuses(getJobsFromQueue(jqueue.getQueueName()));
 }
 return jqueue;
}

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

private void checkHierarchy(Queue queue, QueueManager queueManager) {
 JobQueueInfo jobQueueInfo = queueManager.getJobQueueInfo(queue.getName());
 assertEquals(queue.getName(),jobQueueInfo.getQueueName());
 assertEquals(queue.getState(),jobQueueInfo.getState());
 if (queue.getChildren() !=null && queue.getChildren().size() > 0) {
  for (Queue childQueue : queue.getChildren()) {
   checkHierarchy(childQueue, queueManager);
  }
 }
}