本文整理了Java中org.apache.hadoop.yarn.api.ApplicationClientProtocol.getQueueInfo()
方法的一些代码示例,展示了ApplicationClientProtocol.getQueueInfo()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ApplicationClientProtocol.getQueueInfo()
方法的具体详情如下:
包路径:org.apache.hadoop.yarn.api.ApplicationClientProtocol
类名称:ApplicationClientProtocol
方法名:getQueueInfo
[英]The interface used by clients to get information about queues from the ResourceManager
.
The client, via GetQueueInfoRequest, can ask for details such as used/total resources, child queues, running applications etc.
In secure mode,the ResourceManager
verifies access before providing the information.
[中]客户端用于从ResourceManager
获取有关队列的信息的接口。
客户机可以通过GetQueueInfoRequest询问详细信息,如已使用/总资源、子队列、正在运行的应用程序等。
在安全模式下,ResourceManager
在提供信息之前验证访问权限。
代码示例来源:origin: org.apache.hadoop/hadoop-yarn-server-router
@Override
public GetQueueInfoResponse getQueueInfo(GetQueueInfoRequest request)
throws YarnException, IOException {
return clientRMProxy.getQueueInfo(request);
}
代码示例来源:origin: org.apache.hadoop/hadoop-yarn-client
@Override
public List<QueueInfo> getAllQueues() throws YarnException,
IOException {
List<QueueInfo> queues = new ArrayList<QueueInfo>();
QueueInfo rootQueue =
rmClient.getQueueInfo(getQueueInfoRequest(ROOT, false, true, true))
.getQueueInfo();
getChildQueues(rootQueue, queues, true);
return queues;
}
代码示例来源:origin: io.hops/hadoop-yarn-client
@Override
public List<QueueInfo> getRootQueueInfos() throws YarnException,
IOException {
List<QueueInfo> queues = new ArrayList<QueueInfo>();
QueueInfo rootQueue =
rmClient.getQueueInfo(getQueueInfoRequest(ROOT, false, true, true))
.getQueueInfo();
getChildQueues(rootQueue, queues, false);
return queues;
}
代码示例来源:origin: io.hops/hadoop-yarn-client
@Override
public List<QueueInfo> getChildQueueInfos(String parent)
throws YarnException, IOException {
List<QueueInfo> queues = new ArrayList<QueueInfo>();
QueueInfo parentQueue =
rmClient.getQueueInfo(getQueueInfoRequest(parent, false, true, false))
.getQueueInfo();
getChildQueues(parentQueue, queues, true);
return queues;
}
代码示例来源:origin: ch.cern.hadoop/hadoop-yarn-client
@Override
public List<QueueInfo> getRootQueueInfos() throws YarnException,
IOException {
List<QueueInfo> queues = new ArrayList<QueueInfo>();
QueueInfo rootQueue =
rmClient.getQueueInfo(getQueueInfoRequest(ROOT, false, true, true))
.getQueueInfo();
getChildQueues(rootQueue, queues, false);
return queues;
}
代码示例来源:origin: ch.cern.hadoop/hadoop-yarn-client
@Override
public List<QueueInfo> getAllQueues() throws YarnException,
IOException {
List<QueueInfo> queues = new ArrayList<QueueInfo>();
QueueInfo rootQueue =
rmClient.getQueueInfo(getQueueInfoRequest(ROOT, false, true, true))
.getQueueInfo();
getChildQueues(rootQueue, queues, true);
return queues;
}
代码示例来源:origin: com.github.jiayuhan-it/hadoop-yarn-client
@Override
public List<QueueInfo> getRootQueueInfos() throws YarnException,
IOException {
List<QueueInfo> queues = new ArrayList<QueueInfo>();
QueueInfo rootQueue =
rmClient.getQueueInfo(getQueueInfoRequest(ROOT, false, true, true))
.getQueueInfo();
getChildQueues(rootQueue, queues, false);
return queues;
}
代码示例来源:origin: io.hops/hadoop-yarn-client
@Override
public List<QueueInfo> getAllQueues() throws YarnException,
IOException {
List<QueueInfo> queues = new ArrayList<QueueInfo>();
QueueInfo rootQueue =
rmClient.getQueueInfo(getQueueInfoRequest(ROOT, false, true, true))
.getQueueInfo();
getChildQueues(rootQueue, queues, true);
return queues;
}
代码示例来源:origin: com.github.jiayuhan-it/hadoop-yarn-client
@Override
public List<QueueInfo> getChildQueueInfos(String parent)
throws YarnException, IOException {
List<QueueInfo> queues = new ArrayList<QueueInfo>();
QueueInfo parentQueue =
rmClient.getQueueInfo(getQueueInfoRequest(parent, false, true, false))
.getQueueInfo();
getChildQueues(parentQueue, queues, true);
return queues;
}
代码示例来源:origin: org.apache.hadoop/hadoop-yarn-client
@Override
public List<QueueInfo> getRootQueueInfos() throws YarnException,
IOException {
List<QueueInfo> queues = new ArrayList<QueueInfo>();
QueueInfo rootQueue =
rmClient.getQueueInfo(getQueueInfoRequest(ROOT, false, true, true))
.getQueueInfo();
getChildQueues(rootQueue, queues, false);
return queues;
}
代码示例来源:origin: org.apache.hadoop/hadoop-yarn-client
@Override
public List<QueueInfo> getChildQueueInfos(String parent)
throws YarnException, IOException {
List<QueueInfo> queues = new ArrayList<QueueInfo>();
QueueInfo parentQueue =
rmClient.getQueueInfo(getQueueInfoRequest(parent, false, true, false))
.getQueueInfo();
getChildQueues(parentQueue, queues, true);
return queues;
}
代码示例来源:origin: ch.cern.hadoop/hadoop-yarn-client
@Override
public List<QueueInfo> getChildQueueInfos(String parent)
throws YarnException, IOException {
List<QueueInfo> queues = new ArrayList<QueueInfo>();
QueueInfo parentQueue =
rmClient.getQueueInfo(getQueueInfoRequest(parent, false, true, false))
.getQueueInfo();
getChildQueues(parentQueue, queues, true);
return queues;
}
代码示例来源:origin: com.github.jiayuhan-it/hadoop-yarn-client
@Override
public List<QueueInfo> getAllQueues() throws YarnException,
IOException {
List<QueueInfo> queues = new ArrayList<QueueInfo>();
QueueInfo rootQueue =
rmClient.getQueueInfo(getQueueInfoRequest(ROOT, false, true, true))
.getQueueInfo();
getChildQueues(rootQueue, queues, true);
return queues;
}
代码示例来源:origin: org.apache.hadoop/hadoop-yarn-client
@Override
public QueueInfo getQueueInfo(String queueName) throws YarnException,
IOException {
GetQueueInfoRequest request =
getQueueInfoRequest(queueName, true, false, false);
Records.newRecord(GetQueueInfoRequest.class);
return rmClient.getQueueInfo(request).getQueueInfo();
}
代码示例来源:origin: io.hops/hadoop-yarn-client
@Override
public QueueInfo getQueueInfo(String queueName) throws YarnException,
IOException {
GetQueueInfoRequest request =
getQueueInfoRequest(queueName, true, false, false);
Records.newRecord(GetQueueInfoRequest.class);
return rmClient.getQueueInfo(request).getQueueInfo();
}
代码示例来源:origin: ch.cern.hadoop/hadoop-yarn-client
@Override
public QueueInfo getQueueInfo(String queueName) throws YarnException,
IOException {
GetQueueInfoRequest request =
getQueueInfoRequest(queueName, true, false, false);
Records.newRecord(GetQueueInfoRequest.class);
return rmClient.getQueueInfo(request).getQueueInfo();
}
代码示例来源:origin: com.github.jiayuhan-it/hadoop-yarn-client
@Override
public QueueInfo getQueueInfo(String queueName) throws YarnException,
IOException {
GetQueueInfoRequest request =
getQueueInfoRequest(queueName, true, false, false);
Records.newRecord(GetQueueInfoRequest.class);
return rmClient.getQueueInfo(request).getQueueInfo();
}
代码示例来源:origin: org.apache.hadoop/hadoop-yarn-common
@Override
public GetQueueInfoResponseProto getQueueInfo(RpcController controller,
GetQueueInfoRequestProto proto) throws ServiceException {
GetQueueInfoRequestPBImpl request =
new GetQueueInfoRequestPBImpl(proto);
try {
GetQueueInfoResponse response = real.getQueueInfo(request);
return ((GetQueueInfoResponsePBImpl)response).getProto();
} catch (YarnException e) {
throw new ServiceException(e);
} catch (IOException e) {
throw new ServiceException(e);
}
}
代码示例来源:origin: com.github.jiayuhan-it/hadoop-yarn-common
@Override
public GetQueueInfoResponseProto getQueueInfo(RpcController controller,
GetQueueInfoRequestProto proto) throws ServiceException {
GetQueueInfoRequestPBImpl request =
new GetQueueInfoRequestPBImpl(proto);
try {
GetQueueInfoResponse response = real.getQueueInfo(request);
return ((GetQueueInfoResponsePBImpl)response).getProto();
} catch (YarnException e) {
throw new ServiceException(e);
} catch (IOException e) {
throw new ServiceException(e);
}
}
代码示例来源:origin: ch.cern.hadoop/hadoop-yarn-common
@Override
public GetQueueInfoResponseProto getQueueInfo(RpcController controller,
GetQueueInfoRequestProto proto) throws ServiceException {
GetQueueInfoRequestPBImpl request =
new GetQueueInfoRequestPBImpl(proto);
try {
GetQueueInfoResponse response = real.getQueueInfo(request);
return ((GetQueueInfoResponsePBImpl)response).getProto();
} catch (YarnException e) {
throw new ServiceException(e);
} catch (IOException e) {
throw new ServiceException(e);
}
}
内容来源于网络,如有侵权,请联系作者删除!