本文整理了Java中org.apache.hadoop.yarn.api.ApplicationClientProtocol.listReservations()
方法的一些代码示例,展示了ApplicationClientProtocol.listReservations()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ApplicationClientProtocol.listReservations()
方法的具体详情如下:
包路径:org.apache.hadoop.yarn.api.ApplicationClientProtocol
类名称:ApplicationClientProtocol
方法名:listReservations
[英]The interface used by clients to get the list of reservations in a plan. The reservationId will be used to search for reservations to list if it is provided. Otherwise, it will select active reservations within the startTime and endTime (inclusive).
[中]客户端用于获取计划中的预订列表的接口。reservationId将用于搜索要列出的预订(如果提供)。否则,它将在开始时间和结束时间(包括)内选择活动预订。
代码示例来源:origin: org.apache.hadoop/hadoop-yarn-client
@Override
public ReservationListResponse listReservations(
ReservationListRequest request) throws YarnException, IOException {
return rmClient.listReservations(request);
}
代码示例来源:origin: org.apache.hadoop/hadoop-yarn-server-router
@Override
public ReservationListResponse listReservations(
ReservationListRequest request) throws YarnException, IOException {
return clientRMProxy.listReservations(request);
}
代码示例来源:origin: io.hops/hadoop-yarn-client
@Override
public ReservationListResponse listReservations(
ReservationListRequest request) throws YarnException, IOException {
return rmClient.listReservations(request);
}
代码示例来源:origin: org.apache.hadoop/hadoop-yarn-common
@Override
public ReservationListResponseProto listReservations(RpcController controller,
ReservationListRequestProto requestProto) throws ServiceException {
ReservationListRequestPBImpl request =
new ReservationListRequestPBImpl(requestProto);
try {
ReservationListResponse response = real.listReservations(request);
return ((ReservationListResponsePBImpl) response).getProto();
} catch (YarnException e) {
throw new ServiceException(e);
} catch (IOException e) {
throw new ServiceException(e);
}
}
代码示例来源:origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager
private ReservationListResponse listReservation(String lister,
String queueName) throws Exception {
final ReservationListRequest listRequest =
ReservationListRequest.newInstance(queueName, null, -1, -1, false);
ApplicationClientProtocol ownerClient = getRMClientForUser(lister);
return ownerClient.listReservations(listRequest);
}
代码示例来源:origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager
private ReservationListResponse listReservationById(String lister,
ReservationId reservationId, String queueName) throws Exception {
final ReservationListRequest listRequest =
ReservationListRequest.newInstance(queueName, reservationId
.toString(), -1, -1, false);
ApplicationClientProtocol ownerClient = getRMClientForUser(lister);
return ownerClient.listReservations(listRequest);
}
内容来源于网络,如有侵权,请联系作者删除!