本文整理汇总了Java中org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateResponse类的典型用法代码示例。如果您正苦于以下问题：Java ReservationUpdateResponse类的具体用法？Java ReservationUpdateResponse怎么用？Java ReservationUpdateResponse使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
ReservationUpdateResponse类属于org.apache.hadoop.yarn.api.protocolrecords包，在下文中一共展示了ReservationUpdateResponse类的12个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: updateReservation
import org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateResponse; //导入依赖的package包/类
@Override
public ReservationUpdateResponse updateReservation(ReservationUpdateRequest request)
throws YarnException, IOException {
ReservationUpdateRequestProto requestProto =
((ReservationUpdateRequestPBImpl) request).getProto();
try {
return new ReservationUpdateResponsePBImpl(proxy.updateReservation(null,
requestProto));
} catch (ServiceException e) {
RPCUtil.unwrapAndThrowException(e);
return null;
}
}
开发者ID:naver，项目名称:hadoop，代码行数:14，代码来源:ApplicationClientProtocolPBClientImpl.java
示例2: updateReservation
import org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateResponse; //导入依赖的package包/类
@Override
public ReservationUpdateResponse updateReservation(
ReservationUpdateRequest request) throws YarnException, IOException {
// Check if reservation system is enabled
checkReservationSytem(AuditConstants.UPDATE_RESERVATION_REQUEST);
ReservationUpdateResponse response =
recordFactory.newRecordInstance(ReservationUpdateResponse.class);
// Validate the input
Plan plan =
rValidator.validateReservationUpdateRequest(reservationSystem, request);
ReservationId reservationId = request.getReservationId();
String queueName = reservationSystem.getQueueForReservation(reservationId);
// Check ACLs
String user =
checkReservationACLs(queueName,
AuditConstants.UPDATE_RESERVATION_REQUEST);
// Try to update the reservation using default agent
try {
boolean result =
plan.getReservationAgent().updateReservation(reservationId, user,
plan, request.getReservationDefinition());
if (!result) {
String errMsg = "Unable to update reservation: " + reservationId;
RMAuditLogger.logFailure(user,
AuditConstants.UPDATE_RESERVATION_REQUEST, errMsg,
"ClientRMService", errMsg);
throw RPCUtil.getRemoteException(errMsg);
}
} catch (PlanningException e) {
RMAuditLogger.logFailure(user, AuditConstants.UPDATE_RESERVATION_REQUEST,
e.getMessage(), "ClientRMService",
"Unable to update the reservation: " + reservationId);
throw RPCUtil.getRemoteException(e);
}
RMAuditLogger.logSuccess(user, AuditConstants.UPDATE_RESERVATION_REQUEST,
"ClientRMService: " + reservationId);
return response;
}
开发者ID:naver，项目名称:hadoop，代码行数:39，代码来源:ClientRMService.java
示例3: updateReservation
import org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateResponse; //导入依赖的package包/类
@Override
public ReservationUpdateResponse updateReservation(
ReservationUpdateRequest request) throws YarnException, IOException {
// Check if reservation system is enabled
checkReservationSytem(AuditConstants.UPDATE_RESERVATION_REQUEST);
ReservationUpdateResponse response =
recordFactory.newRecordInstance(ReservationUpdateResponse.class);
// Validate the input
Plan plan =
rValidator.validateReservationUpdateRequest(reservationSystem, request);
ReservationId reservationId = request.getReservationId();
String queueName = reservationSystem.getQueueForReservation(reservationId);
// Check ACLs
String user =
checkReservationACLs(queueName,
AuditConstants.UPDATE_RESERVATION_REQUEST, reservationId);
// Try to update the reservation using default agent
try {
boolean result =
plan.getReservationAgent().updateReservation(reservationId, user,
plan, request.getReservationDefinition());
if (!result) {
String errMsg = "Unable to update reservation: " + reservationId;
RMAuditLogger.logFailure(user,
AuditConstants.UPDATE_RESERVATION_REQUEST, errMsg,
"ClientRMService", errMsg);
throw RPCUtil.getRemoteException(errMsg);
}
} catch (PlanningException e) {
RMAuditLogger.logFailure(user, AuditConstants.UPDATE_RESERVATION_REQUEST,
e.getMessage(), "ClientRMService",
"Unable to update the reservation: " + reservationId);
throw RPCUtil.getRemoteException(e);
}
RMAuditLogger.logSuccess(user, AuditConstants.UPDATE_RESERVATION_REQUEST,
"ClientRMService: " + reservationId);
return response;
}
开发者ID:hopshadoop，项目名称:hops，代码行数:39，代码来源:ClientRMService.java
示例4: testUpdateReservation
import org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateResponse; //导入依赖的package包/类
@Test
public void testUpdateReservation() {
ResourceManager rm = setupResourceManager();
ClientRMService clientService = rm.getClientRMService();
Clock clock = new UTCClock();
long arrival = clock.getTime();
long duration = 60000;
long deadline = (long) (arrival + 1.05 * duration);
ReservationSubmissionRequest sRequest =
submitReservationTestHelper(clientService, arrival, deadline, duration);
ReservationDefinition rDef = sRequest.getReservationDefinition();
ReservationRequest rr =
rDef.getReservationRequests().getReservationResources().get(0);
ReservationId reservationID = sRequest.getReservationId();
rr.setNumContainers(5);
arrival = clock.getTime();
duration = 30000;
deadline = (long) (arrival + 1.05 * duration);
rr.setDuration(duration);
rDef.setArrival(arrival);
rDef.setDeadline(deadline);
ReservationUpdateRequest uRequest =
ReservationUpdateRequest.newInstance(rDef, reservationID);
ReservationUpdateResponse uResponse = null;
try {
uResponse = clientService.updateReservation(uRequest);
} catch (Exception e) {
Assert.fail(e.getMessage());
}
Assert.assertNotNull(uResponse);
System.out.println("Update reservation response: " + uResponse);
rm.stop();
}
开发者ID:hopshadoop，项目名称:hops，代码行数:36，代码来源:TestClientRMService.java
示例5: testUpdateReservation
import org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateResponse; //导入依赖的package包/类
@Test
public void testUpdateReservation() throws Exception {
MiniYARNCluster cluster = setupMiniYARNCluster();
YarnClient client = setupYarnClient(cluster);
try {
Clock clock = new UTCClock();
long arrival = clock.getTime();
long duration = 60000;
long deadline = (long) (arrival + 1.05 * duration);
ReservationSubmissionRequest sRequest =
submitReservationTestHelper(client, arrival, deadline, duration);
ReservationDefinition rDef = sRequest.getReservationDefinition();
ReservationRequest rr =
rDef.getReservationRequests().getReservationResources().get(0);
ReservationId reservationID = sRequest.getReservationId();
rr.setNumContainers(5);
arrival = clock.getTime();
duration = 30000;
deadline = (long) (arrival + 1.05 * duration);
rr.setDuration(duration);
rDef.setArrival(arrival);
rDef.setDeadline(deadline);
ReservationUpdateRequest uRequest =
ReservationUpdateRequest.newInstance(rDef, reservationID);
ReservationUpdateResponse uResponse = client.updateReservation(uRequest);
Assert.assertNotNull(uResponse);
System.out.println("Update reservation response: " + uResponse);
} finally {
// clean-up
if (client != null) {
client.stop();
}
cluster.stop();
}
}
开发者ID:hopshadoop，项目名称:hops，代码行数:37，代码来源:TestYarnClient.java
示例6: updateReservation
import org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateResponse; //导入依赖的package包/类
@Override
public ReservationUpdateResponse updateReservation(
ReservationUpdateRequest request) throws YarnException, IOException {
return rmClient.updateReservation(request);
}
开发者ID:naver，项目名称:hadoop，代码行数:6，代码来源:YarnClientImpl.java
示例7: updateReservation
import org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateResponse; //导入依赖的package包/类
@Override
public ReservationUpdateResponse updateReservation(
ReservationUpdateRequest request) throws YarnException, IOException {
return client.updateReservation(request);
}
开发者ID:naver，项目名称:hadoop，代码行数:6，代码来源:ResourceMgrDelegate.java
示例8: updateReservation
import org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateResponse; //导入依赖的package包/类
@Override
public ReservationUpdateResponse updateReservation(
ReservationUpdateRequest request) throws YarnException, IOException {
return null;
}
开发者ID:naver，项目名称:hadoop，代码行数:6，代码来源:TestClientRedirect.java
示例9: updateReservation
import org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateResponse; //导入依赖的package包/类
@Override
public ReservationUpdateResponse updateReservation(ReservationUpdateRequest arg0)
throws YarnException, IOException {
// TODO Auto-generated method stub
return null;
}
开发者ID:intel-hpdd，项目名称:scheduling-connector-for-hadoop，代码行数:7，代码来源:HPCApplicationClientProtocolImpl.java
示例10: updateReservation
import org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateResponse; //导入依赖的package包/类
@Override
public ReservationUpdateResponse updateReservation(
ReservationUpdateRequest request) throws YarnException, IOException {
throw new NotImplementedException();
}
开发者ID:aliyun-beta，项目名称:aliyun-oss-hadoop-fs，代码行数:6，代码来源:MockResourceManagerFacade.java
示例11: updateReservation
import org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateResponse; //导入依赖的package包/类
/**
* <p>
* The interface used by clients to update an existing Reservation. This is
* referred to as a re-negotiation process, in which a user that has
* previously submitted a Reservation.
* </p>
*
* <p>
* The allocation is attempted by virtually substituting all previous
* allocations related to this Reservation with new ones, that satisfy the new
* {@link ReservationDefinition}. Upon success the previous allocation is
* atomically substituted by the new one, and on failure (i.e., if the system
* cannot find a valid allocation for the updated request), the previous
* allocation remains valid.
* </p>
*
* @param request to update an existing Reservation (the
* {@link ReservationUpdateRequest} should refer to an existing valid
* {@link ReservationId})
* @return response empty on successfully updating the existing reservation
* @throws YarnException if the request is invalid or reservation cannot be
* updated successfully
* @throws IOException
*
*/
@Public
@Unstable
public abstract ReservationUpdateResponse updateReservation(
ReservationUpdateRequest request) throws YarnException, IOException;
开发者ID:naver，项目名称:hadoop，代码行数:30，代码来源:YarnClient.java
示例12: updateReservation
import org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateResponse; //导入依赖的package包/类
/**
* <p>
* The interface used by clients to update an existing Reservation. This is
* referred to as a re-negotiation process, in which a user that has
* previously submitted a Reservation.
* </p>
*
* <p>
* The allocation is attempted by virtually substituting all previous
* allocations related to this Reservation with new ones, that satisfy the new
* {@link ReservationUpdateRequest}. Upon success the previous allocation is
* substituted by the new one, and on failure (i.e., if the system cannot find
* a valid allocation for the updated request), the previous allocation
* remains valid.
*
* The {@link ReservationId} is not changed, and applications currently
* running within this reservation will automatically receive the resources
* based on the new allocation.
* </p>
*
* @param request to update an existing Reservation (the ReservationRequest
* should refer to an existing valid {@link ReservationId})
* @return response empty on successfully updating the existing reservation
* @throws YarnException if the request is invalid or reservation cannot be
* updated successfully
* @throws IOException
*
*/
@Public
@Unstable
public ReservationUpdateResponse updateReservation(
ReservationUpdateRequest request) throws YarnException, IOException;
开发者ID:naver，项目名称:hadoop，代码行数:33，代码来源:ApplicationClientProtocol.java
注：本文中的org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateResponse类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论