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

YarnClient.getQueueInfo介绍

[英]Get information ( QueueInfo) about a given queue.
[中]获取关于给定队列的信息（QueueInfo）。

代码示例

代码示例来源：origin: alibaba/jstorm

LOG.info("Got Cluster node info from ASM, count is " + String.valueOf(clusterNodeReports.size()));
QueueInfo queueInfo = jstormClientContext.yarnClient.getQueueInfo(this.jstormClientContext.amQueue);
LOG.info("Queue info"
    + ", queueName=" + queueInfo.getQueueName()

代码示例来源：origin: apache/metron

QueueInfo queueInfo = yarnClient.getQueueInfo(this.amQueue);
LOG.info("Queue info"
    + ", queueName=" + queueInfo.getQueueName()

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

@Override
public org.apache.hadoop.yarn.api.records.QueueInfo getQueueInfo(
  String queueName) throws YarnException, IOException {
 return client.getQueueInfo(queueName);
}

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

@Override
public org.apache.hadoop.yarn.api.records.QueueInfo getQueueInfo(
  String queueName) throws YarnException, IOException {
 return client.getQueueInfo(queueName);
}

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

public QueueInfo getQueue(String queueName) throws IOException,
InterruptedException {
 try {
  org.apache.hadoop.yarn.api.records.QueueInfo queueInfo =
    client.getQueueInfo(queueName);
  return (queueInfo == null) ? null : TypeConverter.fromYarn(queueInfo,
    conf);
 } catch (YarnException e) {
  throw new IOException(e);
 }
}

代码示例来源：origin: org.apache.tez/tez-mapreduce

public QueueInfo getQueue(String queueName) throws IOException,
InterruptedException {
 try {
  org.apache.hadoop.yarn.api.records.QueueInfo queueInfo =
    client.getQueueInfo(queueName);
  return (queueInfo == null) ? null : TypeConverter.fromYarn(queueInfo,
    conf);
  } catch (YarnException e) {
  throw new IOException(e);
 }
}

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

public QueueInfo getQueue(String queueName) throws IOException,
InterruptedException {
 try {
  org.apache.hadoop.yarn.api.records.QueueInfo queueInfo =
    client.getQueueInfo(queueName);
  return (queueInfo == null) ? null : TypeConverter.fromYarn(queueInfo,
    conf);
 } catch (YarnException e) {
  throw new IOException(e);
 }
}

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

/**
 * Lists the Queue Information matching the given queue name
 * 
 * @param queueName
 * @throws YarnException
 * @throws IOException
 */
private int listQueue(String queueName) throws YarnException, IOException {
 int rc;
 PrintWriter writer = new PrintWriter(
   new OutputStreamWriter(sysout, Charset.forName("UTF-8")));
 QueueInfo queueInfo = client.getQueueInfo(queueName);
 if (queueInfo != null) {
  writer.println("Queue Information : ");
  printQueueInfo(writer, queueInfo);
  rc = 0;
 } else {
  writer.println("Cannot get queue from RM by queueName = " + queueName
    + ", please check.");
  rc = -1;
 }
 writer.flush();
 return rc;
}

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

/**
 * Lists the Queue Information matching the given queue name
 * 
 * @param queueName
 * @throws YarnException
 * @throws IOException
 */
private int listQueue(String queueName) throws YarnException, IOException {
 int rc;
 PrintWriter writer = new PrintWriter(
   new OutputStreamWriter(sysout, Charset.forName("UTF-8")));
 QueueInfo queueInfo = client.getQueueInfo(queueName);
 if (queueInfo != null) {
  writer.println("Queue Information : ");
  printQueueInfo(writer, queueInfo);
  rc = 0;
 } else {
  writer.println("Cannot get queue from RM by queueName = " + queueName
    + ", please check.");
  rc = -1;
 }
 writer.flush();
 return rc;
}

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

/**
 * Lists the Queue Information matching the given queue name
 * 
 * @param queueName
 * @throws YarnException
 * @throws IOException
 */
private int listQueue(String queueName) throws YarnException, IOException {
 int rc;
 PrintWriter writer = new PrintWriter(
   new OutputStreamWriter(sysout, Charset.forName("UTF-8")));
 QueueInfo queueInfo = client.getQueueInfo(queueName);
 if (queueInfo != null) {
  writer.println("Queue Information : ");
  printQueueInfo(writer, queueInfo);
  rc = 0;
 } else {
  writer.println("Cannot get queue from RM by queueName = " + queueName
    + ", please check.");
  rc = -1;
 }
 writer.flush();
 return rc;
}

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

/**
 * Lists the Queue Information matching the given queue name
 * 
 * @param queueName
 * @throws YarnException
 * @throws IOException
 */
private int listQueue(String queueName) throws YarnException, IOException {
 int rc;
 PrintWriter writer = new PrintWriter(
   new OutputStreamWriter(sysout, Charset.forName("UTF-8")));
 QueueInfo queueInfo = client.getQueueInfo(queueName);
 if (queueInfo != null) {
  writer.println("Queue Information : ");
  printQueueInfo(writer, queueInfo);
  rc = 0;
 } else {
  writer.println("Cannot get queue from RM by queueName = " + queueName
    + ", please check.");
  rc = -1;
 }
 writer.flush();
 return rc;
}

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

QueueInfo queueInfo = yarnClient.getQueueInfo(this.amQueue);
LOG.info("Queue info"
  + ", queueName=" + queueInfo.getQueueName()

代码示例来源：origin: apache/hama

QueueInfo queueInfo = yarnClient.getQueueInfo("default");
LOG.info("Queue info"
  + ", queueName=" + queueInfo.getQueueName()

代码示例来源：origin: linkedin/dynamometer

LOG.info("Got Cluster metric info from ASM, numNodeManagers=" + clusterMetrics.getNumNodeManagers());
QueueInfo queueInfo = yarnClient.getQueueInfo(this.amQueue);
LOG.info("Queue info"
  + ", queueName=" + queueInfo.getQueueName()

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

for (String queueName : queues) {
 try {
  QueueInfo qInfo = client.getQueueInfo(queueName);
  queuesInfo.add(qInfo);
 } catch (Exception ie) {

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

for (String queueName : queues) {
 try {
  QueueInfo qInfo = client.getQueueInfo(queueName);
  queuesInfo.add(qInfo);
 } catch (Exception ie) {