org.apache.hadoop.yarn.proto.YarnServiceProtos.MoveApplicationAcrossQueuesRequestProto的实例源码

25-04-05 6

如果您对org.apache.hadoop.yarn.proto.YarnServiceProtos.MoveApplicationAcrossQueuesRequestProto的实例源码感兴趣，那

如果您对org.apache.hadoop.yarn.proto.YarnServiceProtos.MoveApplicationAcrossQueuesRequestProto的实例源码感兴趣，那么这篇文章一定是您不可错过的。我们将详细讲解org.apache.hadoop.yarn.proto.YarnServiceProtos.MoveApplicationAcrossQueuesRequestProto的实例源码的各种细节，此外还有关于org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesRequest的实例源码、org.apache.hadoop.yarn.proto.YarnProtos.ApplicationAccessTypeProto的实例源码、org.apache.hadoop.yarn.proto.YarnProtos.ReservationRequestProto的实例源码、org.apache.hadoop.yarn.proto.YarnProtos.ReservationRequestsProto的实例源码的实用技巧。

本文目录一览：

org.apache.hadoop.yarn.proto.YarnServiceProtos.MoveApplicationAcrossQueuesRequestProto的实例源码
org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesRequest的实例源码
org.apache.hadoop.yarn.proto.YarnProtos.ApplicationAccessTypeProto的实例源码
org.apache.hadoop.yarn.proto.YarnProtos.ReservationRequestProto的实例源码
org.apache.hadoop.yarn.proto.YarnProtos.ReservationRequestsProto的实例源码

org.apache.hadoop.yarn.proto.YarnServiceProtos.MoveApplicationAcrossQueuesRequestProto的实例源码

项目：hadoop 文件：ApplicationClientProtocolPBClientImpl.java

@Override
public MoveApplicationAcrossQueuesResponse moveApplicationAcrossQueues(
    MoveApplicationAcrossQueuesRequest request) throws YarnException,IOException {
  MoveApplicationAcrossQueuesRequestProto requestProto =
      ((MoveApplicationAcrossQueuesRequestPBImpl) request).getProto();
  try {
    return new MoveApplicationAcrossQueuesResponsePBImpl(
        proxy.moveApplicationAcrossQueues(null,requestProto));

  } catch (ServiceException e) {
    RPCUtil.unwrapAndThrowException(e);
    return null;
  }
}

项目：aliyun-oss-hadoop-fs 文件：ApplicationClientProtocolPBClientImpl.java

@Override
public MoveApplicationAcrossQueuesResponse moveApplicationAcrossQueues(
    MoveApplicationAcrossQueuesRequest request) throws YarnException,requestProto));

  } catch (ServiceException e) {
    RPCUtil.unwrapAndThrowException(e);
    return null;
  }
}

项目：big-c 文件：ApplicationClientProtocolPBClientImpl.java

@Override
public MoveApplicationAcrossQueuesResponse moveApplicationAcrossQueues(
    MoveApplicationAcrossQueuesRequest request) throws YarnException,requestProto));

  } catch (ServiceException e) {
    RPCUtil.unwrapAndThrowException(e);
    return null;
  }
}

项目：hadoop-2.6.0-cdh5.4.3 文件：ApplicationClientProtocolPBClientImpl.java

@Override
public MoveApplicationAcrossQueuesResponse moveApplicationAcrossQueues(
    MoveApplicationAcrossQueuesRequest request) throws YarnException,requestProto));

  } catch (ServiceException e) {
    RPCUtil.unwrapAndThrowException(e);
    return null;
  }
}

项目：hops 文件：ApplicationClientProtocolPBClientImpl.java

@Override
public MoveApplicationAcrossQueuesResponse moveApplicationAcrossQueues(
    MoveApplicationAcrossQueuesRequest request) throws YarnException,requestProto));

  } catch (ServiceException e) {
    RPCUtil.unwrapAndThrowException(e);
    return null;
  }
}

项目：hadoop-on-lustre2 文件：ApplicationClientProtocolPBClientImpl.java

@Override
public MoveApplicationAcrossQueuesResponse moveApplicationAcrossQueues(
    MoveApplicationAcrossQueuesRequest request) throws YarnException,requestProto));

  } catch (ServiceException e) {
    RPCUtil.unwrapAndThrowException(e);
    return null;
  }
}

项目：hadoop 文件：MoveApplicationAcrossQueuesRequestPBImpl.java

public MoveApplicationAcrossQueuesRequestPBImpl() {
  builder = MoveApplicationAcrossQueuesRequestProto.newBuilder();
}

项目：hadoop 文件：MoveApplicationAcrossQueuesRequestPBImpl.java

public MoveApplicationAcrossQueuesRequestPBImpl(MoveApplicationAcrossQueuesRequestProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：hadoop 文件：MoveApplicationAcrossQueuesRequestPBImpl.java

public MoveApplicationAcrossQueuesRequestProto getProto() {
  mergeLocalToProto();
  proto = viaProto ? proto : builder.build();
  viaProto = true;
  return proto;
}

项目：hadoop 文件：MoveApplicationAcrossQueuesRequestPBImpl.java

private void maybeInitBuilder() {
  if (viaProto || builder == null) {
    builder = MoveApplicationAcrossQueuesRequestProto.newBuilder(proto);
  }
  viaProto = false;
}

项目：aliyun-oss-hadoop-fs 文件：MoveApplicationAcrossQueuesRequestPBImpl.java

public MoveApplicationAcrossQueuesRequestPBImpl() {
  builder = MoveApplicationAcrossQueuesRequestProto.newBuilder();
}

项目：aliyun-oss-hadoop-fs 文件：MoveApplicationAcrossQueuesRequestPBImpl.java

public MoveApplicationAcrossQueuesRequestPBImpl(MoveApplicationAcrossQueuesRequestProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：aliyun-oss-hadoop-fs 文件：MoveApplicationAcrossQueuesRequestPBImpl.java

public MoveApplicationAcrossQueuesRequestProto getProto() {
  mergeLocalToProto();
  proto = viaProto ? proto : builder.build();
  viaProto = true;
  return proto;
}

项目：aliyun-oss-hadoop-fs 文件：MoveApplicationAcrossQueuesRequestPBImpl.java

private void maybeInitBuilder() {
  if (viaProto || builder == null) {
    builder = MoveApplicationAcrossQueuesRequestProto.newBuilder(proto);
  }
  viaProto = false;
}

项目：aliyun-oss-hadoop-fs 文件：TestPBImplRecords.java

@Test
public void testMoveApplicationAcrossQueuesRequestPBImpl() throws Exception {
  validatePBImplRecord(MoveApplicationAcrossQueuesRequestPBImpl.class,MoveApplicationAcrossQueuesRequestProto.class);
}

项目：big-c 文件：MoveApplicationAcrossQueuesRequestPBImpl.java

public MoveApplicationAcrossQueuesRequestPBImpl() {
  builder = MoveApplicationAcrossQueuesRequestProto.newBuilder();
}

项目：big-c 文件：MoveApplicationAcrossQueuesRequestPBImpl.java

public MoveApplicationAcrossQueuesRequestPBImpl(MoveApplicationAcrossQueuesRequestProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：big-c 文件：MoveApplicationAcrossQueuesRequestPBImpl.java

public MoveApplicationAcrossQueuesRequestProto getProto() {
  mergeLocalToProto();
  proto = viaProto ? proto : builder.build();
  viaProto = true;
  return proto;
}

项目：big-c 文件：MoveApplicationAcrossQueuesRequestPBImpl.java

private void maybeInitBuilder() {
  if (viaProto || builder == null) {
    builder = MoveApplicationAcrossQueuesRequestProto.newBuilder(proto);
  }
  viaProto = false;
}

项目：hadoop-2.6.0-cdh5.4.3 文件：MoveApplicationAcrossQueuesRequestPBImpl.java

public MoveApplicationAcrossQueuesRequestPBImpl() {
  builder = MoveApplicationAcrossQueuesRequestProto.newBuilder();
}

项目：hadoop-2.6.0-cdh5.4.3 文件：MoveApplicationAcrossQueuesRequestPBImpl.java

public MoveApplicationAcrossQueuesRequestPBImpl(MoveApplicationAcrossQueuesRequestProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：hadoop-2.6.0-cdh5.4.3 文件：MoveApplicationAcrossQueuesRequestPBImpl.java

public MoveApplicationAcrossQueuesRequestProto getProto() {
  mergeLocalToProto();
  proto = viaProto ? proto : builder.build();
  viaProto = true;
  return proto;
}

项目：hadoop-2.6.0-cdh5.4.3 文件：MoveApplicationAcrossQueuesRequestPBImpl.java

private void maybeInitBuilder() {
  if (viaProto || builder == null) {
    builder = MoveApplicationAcrossQueuesRequestProto.newBuilder(proto);
  }
  viaProto = false;
}

项目：hops 文件：MoveApplicationAcrossQueuesRequestPBImpl.java

public MoveApplicationAcrossQueuesRequestPBImpl() {
  builder = MoveApplicationAcrossQueuesRequestProto.newBuilder();
}

项目：hops 文件：MoveApplicationAcrossQueuesRequestPBImpl.java

public MoveApplicationAcrossQueuesRequestPBImpl(MoveApplicationAcrossQueuesRequestProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：hops 文件：MoveApplicationAcrossQueuesRequestPBImpl.java

public MoveApplicationAcrossQueuesRequestProto getProto() {
  mergeLocalToProto();
  proto = viaProto ? proto : builder.build();
  viaProto = true;
  return proto;
}

项目：hops 文件：MoveApplicationAcrossQueuesRequestPBImpl.java

private void maybeInitBuilder() {
  if (viaProto || builder == null) {
    builder = MoveApplicationAcrossQueuesRequestProto.newBuilder(proto);
  }
  viaProto = false;
}

项目：hops 文件：TestPBImplRecords.java

@Test
public void testMoveApplicationAcrossQueuesRequestPBImpl() throws Exception {
  validatePBImplRecord(MoveApplicationAcrossQueuesRequestPBImpl.class,MoveApplicationAcrossQueuesRequestProto.class);
}

项目：hadoop-on-lustre2 文件：MoveApplicationAcrossQueuesRequestPBImpl.java

public MoveApplicationAcrossQueuesRequestPBImpl() {
  builder = MoveApplicationAcrossQueuesRequestProto.newBuilder();
}

项目：hadoop-on-lustre2 文件：MoveApplicationAcrossQueuesRequestPBImpl.java

public MoveApplicationAcrossQueuesRequestPBImpl(MoveApplicationAcrossQueuesRequestProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：hadoop-on-lustre2 文件：MoveApplicationAcrossQueuesRequestPBImpl.java

public MoveApplicationAcrossQueuesRequestProto getProto() {
  mergeLocalToProto();
  proto = viaProto ? proto : builder.build();
  viaProto = true;
  return proto;
}

项目：hadoop-on-lustre2 文件：MoveApplicationAcrossQueuesRequestPBImpl.java

private void maybeInitBuilder() {
  if (viaProto || builder == null) {
    builder = MoveApplicationAcrossQueuesRequestProto.newBuilder(proto);
  }
  viaProto = false;
}

org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesRequest的实例源码

项目：hadoop 文件：TestMoveApplication.java

@Test
public void testMoveRejectedByScheduler() throws Exception {
  failMove = true;

  // Submit application
  Application application = new Application("user1",resourceManager);
  application.submit();

  // Wait for app to be accepted
  RMApp app = resourceManager.rmContext.getRMApps()
          .get(application.getApplicationId());
  while (app.getState() != RMAppState.ACCEPTED) {
    Thread.sleep(100);
  }

  ClientRMService clientRMService = resourceManager.getClientRMService();
  try {
    // FIFO scheduler does not support moves
    clientRMService.moveApplicationAcrossQueues(
        MoveApplicationAcrossQueuesRequest.newInstance(
            application.getApplicationId(),"newqueue"));
    fail("Should have hit exception");
  } catch (YarnException ex) {
    assertEquals("Move not supported",ex.getCause().getMessage());
  }
}

项目：hadoop 文件：TestMoveApplication.java

@Test (timeout = 10000)
    public
    void testMoveSuccessful() throws Exception {
  MockRM rm1 = new MockRM(conf);
  rm1.start();
  RMApp app = rm1.submitApp(1024);
  ClientRMService clientRMService = rm1.getClientRMService();
  // FIFO scheduler does not support moves
  clientRMService
    .moveApplicationAcrossQueues(MoveApplicationAcrossQueuesRequest
      .newInstance(app.getApplicationId(),"newqueue"));

  RMApp rmApp = rm1.getRMContext().getRMApps().get(app.getApplicationId());
  assertEquals("newqueue",rmApp.getQueue());
  rm1.stop();
}

项目：hadoop 文件：TestMoveApplication.java

@Test
public void testMoveRejectedByPermissions() throws Exception {
  failMove = true;

  // Submit application
  final Application application = new Application("user1",resourceManager);
  application.submit();

  final ClientRMService clientRMService = resourceManager.getClientRMService();
  try {
    UserGroupinformation.createRemoteUser("otheruser").doAs(
        new PrivilegedExceptionAction<MoveApplicationAcrossQueuesResponse>() {
          @Override
          public MoveApplicationAcrossQueuesResponse run() throws Exception {
            return clientRMService.moveApplicationAcrossQueues(
                MoveApplicationAcrossQueuesRequest.newInstance(
                    application.getApplicationId(),"newqueue"));
          }

        });
    fail("Should have hit exception");
  } catch (Exception ex) {
    assertEquals(AccessControlException.class,ex.getCause().getCause().getClass());
  }
}

项目：aliyun-oss-hadoop-fs 文件：TestMoveApplication.java

@Test
public void testMoveRejectedByScheduler() throws Exception {
  failMove = true;

  // Submit application
  Application application = new Application("user1",ex.getCause().getMessage());
  }
}

项目：aliyun-oss-hadoop-fs 文件：TestMoveApplication.java

@Test (timeout = 10000)
    public
    void testMoveSuccessful() throws Exception {
  MockRM rm1 = new MockRM(conf);
  rm1.start();
  RMApp app = rm1.submitApp(1024);
  ClientRMService clientRMService = rm1.getClientRMService();
  // FIFO scheduler does not support moves
  clientRMService
    .moveApplicationAcrossQueues(MoveApplicationAcrossQueuesRequest
      .newInstance(app.getApplicationId(),rmApp.getQueue());
  rm1.stop();
}

项目：aliyun-oss-hadoop-fs 文件：TestMoveApplication.java

@Test
public void testMoveRejectedByPermissions() throws Exception {
  failMove = true;

  // Submit application
  final Application application = new Application("user1",ex.getCause().getCause().getClass());
  }
}

项目：big-c 文件：TestMoveApplication.java

@Test
public void testMoveRejectedByScheduler() throws Exception {
  failMove = true;

  // Submit application
  Application application = new Application("user1",ex.getCause().getMessage());
  }
}

项目：big-c 文件：TestMoveApplication.java

@Test (timeout = 10000)
    public
    void testMoveSuccessful() throws Exception {
  MockRM rm1 = new MockRM(conf);
  rm1.start();
  RMApp app = rm1.submitApp(1024);
  ClientRMService clientRMService = rm1.getClientRMService();
  // FIFO scheduler does not support moves
  clientRMService
    .moveApplicationAcrossQueues(MoveApplicationAcrossQueuesRequest
      .newInstance(app.getApplicationId(),rmApp.getQueue());
  rm1.stop();
}

项目：big-c 文件：TestMoveApplication.java

@Test
public void testMoveRejectedByPermissions() throws Exception {
  failMove = true;

  // Submit application
  final Application application = new Application("user1",ex.getCause().getCause().getClass());
  }
}

项目：hadoop-2.6.0-cdh5.4.3 文件：TestMoveApplication.java

@Test
public void testMoveRejectedByScheduler() throws Exception {
  failMove = true;

  // Submit application
  Application application = new Application("user1",ex.getCause().getMessage());
  }
}

项目：hadoop-2.6.0-cdh5.4.3 文件：TestMoveApplication.java

@Test (timeout = 10000)
    public
    void testMoveSuccessful() throws Exception {
  MockRM rm1 = new MockRM(conf);
  rm1.start();
  RMApp app = rm1.submitApp(1024);
  ClientRMService clientRMService = rm1.getClientRMService();
  // FIFO scheduler does not support moves
  clientRMService
    .moveApplicationAcrossQueues(MoveApplicationAcrossQueuesRequest
      .newInstance(app.getApplicationId(),rmApp.getQueue());
  rm1.stop();
}

项目：hadoop-2.6.0-cdh5.4.3 文件：TestMoveApplication.java

@Test
public void testMoveRejectedByPermissions() throws Exception {
  failMove = true;

  // Submit application
  final Application application = new Application("user1",ex.getCause().getCause().getClass());
  }
}

项目：hops 文件：TestMoveApplication.java

@Test
public void testMoveRejectedByScheduler() throws Exception {
  failMove = true;

  // Submit application
  Application application = new Application("user1",ex.getCause().getMessage());
  }
}

项目：hops 文件：TestMoveApplication.java

@Test (timeout = 10000)
    public
    void testMoveSuccessful() throws Exception {
  MockRM rm1 = new MockRM(conf);
  rm1.start();
  RMApp app = rm1.submitApp(1024);
  ClientRMService clientRMService = rm1.getClientRMService();
  // FIFO scheduler does not support moves
  clientRMService
    .moveApplicationAcrossQueues(MoveApplicationAcrossQueuesRequest
      .newInstance(app.getApplicationId(),rmApp.getQueue());
  rm1.stop();
}

项目：hops 文件：TestMoveApplication.java

@Test
public void testMoveRejectedByPermissions() throws Exception {
  failMove = true;

  // Submit application
  final Application application = new Application("user1",ex.getCause().getCause().getClass());
  }
}

项目：hadoop-on-lustre2 文件：TestMoveApplication.java

@Test
public void testMoveRejectedByScheduler() throws Exception {
  failMove = true;

  // Submit application
  Application application = new Application("user1",resourceManager);
  application.submit();

  ClientRMService clientRMService = resourceManager.getClientRMService();
  try {
    // FIFO scheduler does not support moves
    clientRMService.moveApplicationAcrossQueues(
        MoveApplicationAcrossQueuesRequest.newInstance(
            application.getApplicationId(),ex.getCause().getMessage());
  }
}

项目：hadoop-on-lustre2 文件：TestMoveApplication.java

@Test (timeout = 5000)
public void testMoveSuccessful() throws Exception {
  // Submit application
  Application application = new Application("user1",resourceManager);
  ApplicationId appId = application.getApplicationId();
  application.submit();

  // Wait for app to be accepted
  RMApp app = resourceManager.rmContext.getRMApps().get(appId);
  while (app.getState() != RMAppState.ACCEPTED) {
    Thread.sleep(100);
  }

  ClientRMService clientRMService = resourceManager.getClientRMService();
  // FIFO scheduler does not support moves
  clientRMService.moveApplicationAcrossQueues(
      MoveApplicationAcrossQueuesRequest.newInstance(appId,"newqueue"));

  RMApp rmApp = resourceManager.getRMContext().getRMApps().get(appId);
  assertEquals("newqueue",rmApp.getQueue());
}

项目：hadoop-on-lustre2 文件：TestMoveApplication.java

@Test
public void testMoveRejectedByPermissions() throws Exception {
  failMove = true;

  // Submit application
  final Application application = new Application("user1",ex.getCause().getCause().getClass());
  }
}

项目：hadoop 文件：ApplicationClientProtocolPBClientImpl.java

@Override
public MoveApplicationAcrossQueuesResponse moveApplicationAcrossQueues(
    MoveApplicationAcrossQueuesRequest request) throws YarnException,IOException {
  MoveApplicationAcrossQueuesRequestProto requestProto =
      ((MoveApplicationAcrossQueuesRequestPBImpl) request).getProto();
  try {
    return new MoveApplicationAcrossQueuesResponsePBImpl(
        proxy.moveApplicationAcrossQueues(null,requestProto));

  } catch (ServiceException e) {
    RPCUtil.unwrapAndThrowException(e);
    return null;
  }
}

项目：hadoop 文件：TestMoveApplication.java

@Test (timeout = 10000)
public void testMovetooLate() throws Exception {
  // Submit application
  Application application = new Application("user1",resourceManager);
  ApplicationId appId = application.getApplicationId();
  application.submit();

  ClientRMService clientRMService = resourceManager.getClientRMService();
  // Kill the application
  clientRMService.forceKillApplication(
      KillApplicationRequest.newInstance(appId));
  RMApp rmApp = resourceManager.getRMContext().getRMApps().get(appId);
  // wait until it's dead
  while (rmApp.getState() != RMAppState.KILLED) {
    Thread.sleep(100);
  }

  try {
    clientRMService.moveApplicationAcrossQueues(
        MoveApplicationAcrossQueuesRequest.newInstance(appId,"newqueue"));
    fail("Should have hit exception");
  } catch (YarnException ex) {
    assertEquals(YarnException.class,ex.getClass());
    assertEquals("App in KILLED state cannot be moved.",ex.getMessage());
  }
}

项目：hadoop 文件：TestClientRMService.java

@Test (expected = ApplicationNotFoundException.class)
public void testMoveAbsentApplication() throws YarnException {
  RMContext rmContext = mock(RMContext.class);
  when(rmContext.getRMApps()).thenReturn(
      new ConcurrentHashMap<ApplicationId,RMApp>());
  ClientRMService rmService = new ClientRMService(rmContext,null,null);
  ApplicationId applicationId =
      BuilderUtils.newApplicationId(System.currentTimeMillis(),0);
  MoveApplicationAcrossQueuesRequest request =
      MoveApplicationAcrossQueuesRequest.newInstance(applicationId,"newqueue");
  rmService.moveApplicationAcrossQueues(request);
}

项目：hadoop 文件：YarnClientImpl.java

@Override
public void moveApplicationAcrossQueues(ApplicationId appId,String queue) throws YarnException,IOException {
  MoveApplicationAcrossQueuesRequest request =
      MoveApplicationAcrossQueuesRequest.newInstance(appId,queue);
  rmClient.moveApplicationAcrossQueues(request);
}

项目：hadoop 文件：ProtocolHATestBase.java

@Override
public MoveApplicationAcrossQueuesResponse moveApplicationAcrossQueues(
    MoveApplicationAcrossQueuesRequest request) throws YarnException {
  resetStartFailoverFlag(true);

  // make sure failover has been triggered
  Assert.assertTrue(waittingForFailover());

  return Records.newRecord(MoveApplicationAcrossQueuesResponse.class);
}

项目：scheduling-connector-for-hadoop 文件：HPCApplicationClientProtocolImpl.java

@Override
public MoveApplicationAcrossQueuesResponse moveApplicationAcrossQueues(
    MoveApplicationAcrossQueuesRequest request) throws YarnException,IOException {
  return RecordFactoryProvider.getRecordFactory(null).newRecordInstance(
      MoveApplicationAcrossQueuesResponse.class);
}

项目：aliyun-oss-hadoop-fs 文件：ApplicationClientProtocolPBClientImpl.java

@Override
public MoveApplicationAcrossQueuesResponse moveApplicationAcrossQueues(
    MoveApplicationAcrossQueuesRequest request) throws YarnException,requestProto));

  } catch (ServiceException e) {
    RPCUtil.unwrapAndThrowException(e);
    return null;
  }
}

项目：aliyun-oss-hadoop-fs 文件：TestMoveApplication.java

@Test (timeout = 10000)
public void testMovetooLate() throws Exception {
  // Submit application
  Application application = new Application("user1",ex.getMessage());
  }
}

项目：aliyun-oss-hadoop-fs 文件：TestClientRMService.java

@Test (expected = ApplicationNotFoundException.class)
public void testMoveAbsentApplication() throws YarnException {
  RMContext rmContext = mock(RMContext.class);
  when(rmContext.getRMApps()).thenReturn(
      new ConcurrentHashMap<ApplicationId,"newqueue");
  rmService.moveApplicationAcrossQueues(request);
}

项目：aliyun-oss-hadoop-fs 文件：YarnClientImpl.java

@Override
public void moveApplicationAcrossQueues(ApplicationId appId,queue);
  rmClient.moveApplicationAcrossQueues(request);
}

项目：aliyun-oss-hadoop-fs 文件：ProtocolHATestBase.java

@Override
public MoveApplicationAcrossQueuesResponse moveApplicationAcrossQueues(
    MoveApplicationAcrossQueuesRequest request) throws YarnException {
  resetStartFailoverFlag(true);

  // make sure failover has been triggered
  Assert.assertTrue(waittingForFailover());

  return Records.newRecord(MoveApplicationAcrossQueuesResponse.class);
}

项目：big-c 文件：ApplicationClientProtocolPBClientImpl.java

@Override
public MoveApplicationAcrossQueuesResponse moveApplicationAcrossQueues(
    MoveApplicationAcrossQueuesRequest request) throws YarnException,requestProto));

  } catch (ServiceException e) {
    RPCUtil.unwrapAndThrowException(e);
    return null;
  }
}

项目：big-c 文件：TestMoveApplication.java

@Test (timeout = 10000)
public void testMovetooLate() throws Exception {
  // Submit application
  Application application = new Application("user1",ex.getMessage());
  }
}

项目：big-c 文件：TestClientRMService.java

@Test (expected = ApplicationNotFoundException.class)
public void testMoveAbsentApplication() throws YarnException {
  RMContext rmContext = mock(RMContext.class);
  when(rmContext.getRMApps()).thenReturn(
      new ConcurrentHashMap<ApplicationId,"newqueue");
  rmService.moveApplicationAcrossQueues(request);
}

项目：big-c 文件：YarnClientImpl.java

@Override
public void moveApplicationAcrossQueues(ApplicationId appId,queue);
  rmClient.moveApplicationAcrossQueues(request);
}

项目：big-c 文件：ProtocolHATestBase.java

@Override
public MoveApplicationAcrossQueuesResponse moveApplicationAcrossQueues(
    MoveApplicationAcrossQueuesRequest request) throws YarnException {
  resetStartFailoverFlag(true);

  // make sure failover has been triggered
  Assert.assertTrue(waittingForFailover());

  return Records.newRecord(MoveApplicationAcrossQueuesResponse.class);
}

项目：hadoop-2.6.0-cdh5.4.3 文件：ApplicationClientProtocolPBClientImpl.java

@Override
public MoveApplicationAcrossQueuesResponse moveApplicationAcrossQueues(
    MoveApplicationAcrossQueuesRequest request) throws YarnException,requestProto));

  } catch (ServiceException e) {
    RPCUtil.unwrapAndThrowException(e);
    return null;
  }
}

项目：hadoop-2.6.0-cdh5.4.3 文件：TestMoveApplication.java

@Test (timeout = 10000)
public void testMovetooLate() throws Exception {
  // Submit application
  Application application = new Application("user1",ex.getMessage());
  }
}

项目：hadoop-2.6.0-cdh5.4.3 文件：TestClientRMService.java

@Test (expected = ApplicationNotFoundException.class)
public void testMoveAbsentApplication() throws YarnException {
  RMContext rmContext = mock(RMContext.class);
  when(rmContext.getRMApps()).thenReturn(
      new ConcurrentHashMap<ApplicationId,"newqueue");
  rmService.moveApplicationAcrossQueues(request);
}

项目：hadoop-2.6.0-cdh5.4.3 文件：YarnClientImpl.java

@Override
public void moveApplicationAcrossQueues(ApplicationId appId,queue);
  rmClient.moveApplicationAcrossQueues(request);
}

项目：hadoop-2.6.0-cdh5.4.3 文件：ProtocolHATestBase.java

@Override
public MoveApplicationAcrossQueuesResponse moveApplicationAcrossQueues(
    MoveApplicationAcrossQueuesRequest request) throws YarnException {
  resetStartFailoverFlag(true);

  // make sure failover has been triggered
  Assert.assertTrue(waittingForFailover());

  return Records.newRecord(MoveApplicationAcrossQueuesResponse.class);
}

项目：hops 文件：ApplicationClientProtocolPBClientImpl.java

@Override
public MoveApplicationAcrossQueuesResponse moveApplicationAcrossQueues(
    MoveApplicationAcrossQueuesRequest request) throws YarnException,requestProto));

  } catch (ServiceException e) {
    RPCUtil.unwrapAndThrowException(e);
    return null;
  }
}

org.apache.hadoop.yarn.proto.YarnProtos.ApplicationAccessTypeProto的实例源码

项目：hadoop 文件：ProtoUtils.java

public static ApplicationAccesstypeProto convertToProtoFormat(
    ApplicationAccesstype e) {
  return ApplicationAccesstypeProto.valueOf(APP_ACCESS_TYPE_PREFIX
      + e.name());
}

项目：hadoop 文件：ProtoUtils.java

public static ApplicationAccesstype convertFromProtoFormat(
    ApplicationAccesstypeProto e) {
  return ApplicationAccesstype.valueOf(e.name().replace(
      APP_ACCESS_TYPE_PREFIX,""));
}

项目：aliyun-oss-hadoop-fs 文件：ProtoUtils.java

public static ApplicationAccesstypeProto convertToProtoFormat(
    ApplicationAccesstype e) {
  return ApplicationAccesstypeProto.valueOf(APP_ACCESS_TYPE_PREFIX
      + e.name());
}

项目：aliyun-oss-hadoop-fs 文件：ProtoUtils.java

public static ApplicationAccesstype convertFromProtoFormat(
    ApplicationAccesstypeProto e) {
  return ApplicationAccesstype.valueOf(e.name().replace(
      APP_ACCESS_TYPE_PREFIX,""));
}

项目：big-c 文件：ProtoUtils.java

public static ApplicationAccesstypeProto convertToProtoFormat(
    ApplicationAccesstype e) {
  return ApplicationAccesstypeProto.valueOf(APP_ACCESS_TYPE_PREFIX
      + e.name());
}

项目：big-c 文件：ProtoUtils.java

public static ApplicationAccesstype convertFromProtoFormat(
    ApplicationAccesstypeProto e) {
  return ApplicationAccesstype.valueOf(e.name().replace(
      APP_ACCESS_TYPE_PREFIX,""));
}

项目：hadoop-2.6.0-cdh5.4.3 文件：ProtoUtils.java

public static ApplicationAccesstypeProto convertToProtoFormat(
    ApplicationAccesstype e) {
  return ApplicationAccesstypeProto.valueOf(APP_ACCESS_TYPE_PREFIX
      + e.name());
}

项目：hadoop-2.6.0-cdh5.4.3 文件：ProtoUtils.java

public static ApplicationAccesstype convertFromProtoFormat(
    ApplicationAccesstypeProto e) {
  return ApplicationAccesstype.valueOf(e.name().replace(
      APP_ACCESS_TYPE_PREFIX,""));
}

项目：hadoop-plus 文件：ProtoUtils.java

public static ApplicationAccesstypeProto convertToProtoFormat(
    ApplicationAccesstype e) {
  return ApplicationAccesstypeProto.valueOf(APP_ACCESS_TYPE_PREFIX
      + e.name());
}

项目：hadoop-plus 文件：ProtoUtils.java

public static ApplicationAccesstype convertFromProtoFormat(
    ApplicationAccesstypeProto e) {
  return ApplicationAccesstype.valueOf(e.name().replace(
      APP_ACCESS_TYPE_PREFIX,""));
}

项目：hops 文件：ProtoUtils.java

public static ApplicationAccesstypeProto convertToProtoFormat(
    ApplicationAccesstype e) {
  return ApplicationAccesstypeProto.valueOf(APP_ACCESS_TYPE_PREFIX
      + e.name());
}

项目：hops 文件：ProtoUtils.java

public static ApplicationAccesstype convertFromProtoFormat(
    ApplicationAccesstypeProto e) {
  return ApplicationAccesstype.valueOf(e.name().replace(
      APP_ACCESS_TYPE_PREFIX,""));
}

项目：hadoop-TCP 文件：ProtoUtils.java

public static ApplicationAccesstypeProto convertToProtoFormat(
    ApplicationAccesstype e) {
  return ApplicationAccesstypeProto.valueOf(APP_ACCESS_TYPE_PREFIX
      + e.name());
}

项目：hadoop-TCP 文件：ProtoUtils.java

public static ApplicationAccesstype convertFromProtoFormat(
    ApplicationAccesstypeProto e) {
  return ApplicationAccesstype.valueOf(e.name().replace(
      APP_ACCESS_TYPE_PREFIX,""));
}

项目：hardfs 文件：ProtoUtils.java

public static ApplicationAccesstypeProto convertToProtoFormat(
    ApplicationAccesstype e) {
  return ApplicationAccesstypeProto.valueOf(APP_ACCESS_TYPE_PREFIX
      + e.name());
}

项目：hardfs 文件：ProtoUtils.java

public static ApplicationAccesstype convertFromProtoFormat(
    ApplicationAccesstypeProto e) {
  return ApplicationAccesstype.valueOf(e.name().replace(
      APP_ACCESS_TYPE_PREFIX,""));
}

项目：hadoop-on-lustre2 文件：ProtoUtils.java

public static ApplicationAccesstypeProto convertToProtoFormat(
    ApplicationAccesstype e) {
  return ApplicationAccesstypeProto.valueOf(APP_ACCESS_TYPE_PREFIX
      + e.name());
}

项目：hadoop-on-lustre2 文件：ProtoUtils.java

public static ApplicationAccesstype convertFromProtoFormat(
    ApplicationAccesstypeProto e) {
  return ApplicationAccesstype.valueOf(e.name().replace(
      APP_ACCESS_TYPE_PREFIX,""));
}

org.apache.hadoop.yarn.proto.YarnProtos.ReservationRequestProto的实例源码

项目：hadoop 文件：ReservationRequestsPBImpl.java

private void initReservationRequestsList() {
  if (this.reservationRequests != null) {
    return;
  }
  ReservationRequestsProtoOrBuilder p = viaProto ? proto : builder;
  List<ReservationRequestProto> resourceProtos =
      p.getReservationResourcesList();
  reservationRequests = new ArrayList<ReservationRequest>();

  for (ReservationRequestProto r : resourceProtos) {
    reservationRequests.add(convertFromProtoFormat(r));
  }
}

项目：hadoop 文件：ReservationRequestsPBImpl.java

private void addReservationResourcesToProto() {
  maybeInitBuilder();
  builder.clearReservationResources();
  if (reservationRequests == null)
    return;
  Iterable<ReservationRequestProto> iterable =
      new Iterable<ReservationRequestProto>() {
        @Override
        public Iterator<ReservationRequestProto> iterator() {
          return new Iterator<ReservationRequestProto>() {

            Iterator<ReservationRequest> iter = reservationRequests
                .iterator();

            @Override
            public boolean hasNext() {
              return iter.hasNext();
            }

            @Override
            public ReservationRequestProto next() {
              return convertToProtoFormat(iter.next());
            }

            @Override
            public void remove() {
              throw new UnsupportedOperationException();
            }

          };

        }

      };
  builder.addAllReservationResources(iterable);
}

项目：aliyun-oss-hadoop-fs 文件：ReservationRequestsPBImpl.java

private void initReservationRequestsList() {
  if (this.reservationRequests != null) {
    return;
  }
  ReservationRequestsProtoOrBuilder p = viaProto ? proto : builder;
  List<ReservationRequestProto> resourceProtos =
      p.getReservationResourcesList();
  reservationRequests = new ArrayList<ReservationRequest>();

  for (ReservationRequestProto r : resourceProtos) {
    reservationRequests.add(convertFromProtoFormat(r));
  }
}

项目：aliyun-oss-hadoop-fs 文件：ReservationRequestsPBImpl.java

private void addReservationResourcesToProto() {
  maybeInitBuilder();
  builder.clearReservationResources();
  if (reservationRequests == null)
    return;
  Iterable<ReservationRequestProto> iterable =
      new Iterable<ReservationRequestProto>() {
        @Override
        public Iterator<ReservationRequestProto> iterator() {
          return new Iterator<ReservationRequestProto>() {

            Iterator<ReservationRequest> iter = reservationRequests
                .iterator();

            @Override
            public boolean hasNext() {
              return iter.hasNext();
            }

            @Override
            public ReservationRequestProto next() {
              return convertToProtoFormat(iter.next());
            }

            @Override
            public void remove() {
              throw new UnsupportedOperationException();
            }

          };

        }

      };
  builder.addAllReservationResources(iterable);
}

项目：big-c 文件：ReservationRequestsPBImpl.java

private void initReservationRequestsList() {
  if (this.reservationRequests != null) {
    return;
  }
  ReservationRequestsProtoOrBuilder p = viaProto ? proto : builder;
  List<ReservationRequestProto> resourceProtos =
      p.getReservationResourcesList();
  reservationRequests = new ArrayList<ReservationRequest>();

  for (ReservationRequestProto r : resourceProtos) {
    reservationRequests.add(convertFromProtoFormat(r));
  }
}

项目：big-c 文件：ReservationRequestsPBImpl.java

private void addReservationResourcesToProto() {
  maybeInitBuilder();
  builder.clearReservationResources();
  if (reservationRequests == null)
    return;
  Iterable<ReservationRequestProto> iterable =
      new Iterable<ReservationRequestProto>() {
        @Override
        public Iterator<ReservationRequestProto> iterator() {
          return new Iterator<ReservationRequestProto>() {

            Iterator<ReservationRequest> iter = reservationRequests
                .iterator();

            @Override
            public boolean hasNext() {
              return iter.hasNext();
            }

            @Override
            public ReservationRequestProto next() {
              return convertToProtoFormat(iter.next());
            }

            @Override
            public void remove() {
              throw new UnsupportedOperationException();
            }

          };

        }

      };
  builder.addAllReservationResources(iterable);
}

项目：hadoop-2.6.0-cdh5.4.3 文件：ReservationRequestsPBImpl.java

private void initReservationRequestsList() {
  if (this.reservationRequests != null) {
    return;
  }
  ReservationRequestsProtoOrBuilder p = viaProto ? proto : builder;
  List<ReservationRequestProto> resourceProtos =
      p.getReservationResourcesList();
  reservationRequests = new ArrayList<ReservationRequest>();

  for (ReservationRequestProto r : resourceProtos) {
    reservationRequests.add(convertFromProtoFormat(r));
  }
}

项目：hadoop-2.6.0-cdh5.4.3 文件：ReservationRequestsPBImpl.java

private void addReservationResourcesToProto() {
  maybeInitBuilder();
  builder.clearReservationResources();
  if (reservationRequests == null)
    return;
  Iterable<ReservationRequestProto> iterable =
      new Iterable<ReservationRequestProto>() {
        @Override
        public Iterator<ReservationRequestProto> iterator() {
          return new Iterator<ReservationRequestProto>() {

            Iterator<ReservationRequest> iter = reservationRequests
                .iterator();

            @Override
            public boolean hasNext() {
              return iter.hasNext();
            }

            @Override
            public ReservationRequestProto next() {
              return convertToProtoFormat(iter.next());
            }

            @Override
            public void remove() {
              throw new UnsupportedOperationException();
            }

          };

        }

      };
  builder.addAllReservationResources(iterable);
}

项目：hops 文件：ReservationRequestsPBImpl.java

private void initReservationRequestsList() {
  if (this.reservationRequests != null) {
    return;
  }
  ReservationRequestsProtoOrBuilder p = viaProto ? proto : builder;
  List<ReservationRequestProto> resourceProtos =
      p.getReservationResourcesList();
  reservationRequests = new ArrayList<ReservationRequest>();

  for (ReservationRequestProto r : resourceProtos) {
    reservationRequests.add(convertFromProtoFormat(r));
  }
}

项目：hops 文件：ReservationRequestsPBImpl.java

private void addReservationResourcesToProto() {
  maybeInitBuilder();
  builder.clearReservationResources();
  if (reservationRequests == null)
    return;
  Iterable<ReservationRequestProto> iterable =
      new Iterable<ReservationRequestProto>() {
        @Override
        public Iterator<ReservationRequestProto> iterator() {
          return new Iterator<ReservationRequestProto>() {

            Iterator<ReservationRequest> iter = reservationRequests
                .iterator();

            @Override
            public boolean hasNext() {
              return iter.hasNext();
            }

            @Override
            public ReservationRequestProto next() {
              return convertToProtoFormat(iter.next());
            }

            @Override
            public void remove() {
              throw new UnsupportedOperationException();
            }

          };

        }

      };
  builder.addAllReservationResources(iterable);
}

项目：hadoop 文件：ReservationRequestsPBImpl.java

private ReservationRequestProto convertToProtoFormat(ReservationRequest r) {
  return ((ReservationRequestPBImpl) r).getProto();
}

项目：hadoop 文件：ReservationRequestsPBImpl.java

private ReservationRequestPBImpl convertFromProtoFormat(
    ReservationRequestProto r) {
  return new ReservationRequestPBImpl(r);
}

项目：hadoop 文件：ReservationRequestPBImpl.java

public ReservationRequestPBImpl() {
  builder = ReservationRequestProto.newBuilder();
}

项目：hadoop 文件：ReservationRequestPBImpl.java

public ReservationRequestPBImpl(ReservationRequestProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：hadoop 文件：ReservationRequestPBImpl.java

public ReservationRequestProto getProto() {
  mergeLocalToProto();
  proto = viaProto ? proto : builder.build();
  viaProto = true;
  return proto;
}

项目：hadoop 文件：ReservationRequestPBImpl.java

private void maybeInitBuilder() {
  if (viaProto || builder == null) {
    builder = ReservationRequestProto.newBuilder(proto);
  }
  viaProto = false;
}

项目：aliyun-oss-hadoop-fs 文件：ReservationRequestsPBImpl.java

private ReservationRequestProto convertToProtoFormat(ReservationRequest r) {
  return ((ReservationRequestPBImpl) r).getProto();
}

项目：aliyun-oss-hadoop-fs 文件：ReservationRequestsPBImpl.java

private ReservationRequestPBImpl convertFromProtoFormat(
    ReservationRequestProto r) {
  return new ReservationRequestPBImpl(r);
}

项目：aliyun-oss-hadoop-fs 文件：ReservationRequestPBImpl.java

public ReservationRequestPBImpl() {
  builder = ReservationRequestProto.newBuilder();
}

项目：aliyun-oss-hadoop-fs 文件：ReservationRequestPBImpl.java

public ReservationRequestPBImpl(ReservationRequestProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：aliyun-oss-hadoop-fs 文件：ReservationRequestPBImpl.java

public ReservationRequestProto getProto() {
  mergeLocalToProto();
  proto = viaProto ? proto : builder.build();
  viaProto = true;
  return proto;
}

项目：aliyun-oss-hadoop-fs 文件：ReservationRequestPBImpl.java

private void maybeInitBuilder() {
  if (viaProto || builder == null) {
    builder = ReservationRequestProto.newBuilder(proto);
  }
  viaProto = false;
}

项目：big-c 文件：ReservationRequestsPBImpl.java

private ReservationRequestProto convertToProtoFormat(ReservationRequest r) {
  return ((ReservationRequestPBImpl) r).getProto();
}

项目：big-c 文件：ReservationRequestsPBImpl.java

private ReservationRequestPBImpl convertFromProtoFormat(
    ReservationRequestProto r) {
  return new ReservationRequestPBImpl(r);
}

项目：big-c 文件：ReservationRequestPBImpl.java

public ReservationRequestPBImpl() {
  builder = ReservationRequestProto.newBuilder();
}

项目：big-c 文件：ReservationRequestPBImpl.java

public ReservationRequestPBImpl(ReservationRequestProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：big-c 文件：ReservationRequestPBImpl.java

public ReservationRequestProto getProto() {
  mergeLocalToProto();
  proto = viaProto ? proto : builder.build();
  viaProto = true;
  return proto;
}

项目：big-c 文件：ReservationRequestPBImpl.java

private void maybeInitBuilder() {
  if (viaProto || builder == null) {
    builder = ReservationRequestProto.newBuilder(proto);
  }
  viaProto = false;
}

项目：hadoop-2.6.0-cdh5.4.3 文件：ReservationRequestsPBImpl.java

private ReservationRequestProto convertToProtoFormat(ReservationRequest r) {
  return ((ReservationRequestPBImpl) r).getProto();
}

项目：hadoop-2.6.0-cdh5.4.3 文件：ReservationRequestsPBImpl.java

private ReservationRequestPBImpl convertFromProtoFormat(
    ReservationRequestProto r) {
  return new ReservationRequestPBImpl(r);
}

项目：hadoop-2.6.0-cdh5.4.3 文件：ReservationRequestPBImpl.java

public ReservationRequestPBImpl() {
  builder = ReservationRequestProto.newBuilder();
}

项目：hadoop-2.6.0-cdh5.4.3 文件：ReservationRequestPBImpl.java

public ReservationRequestPBImpl(ReservationRequestProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：hadoop-2.6.0-cdh5.4.3 文件：ReservationRequestPBImpl.java

public ReservationRequestProto getProto() {
  mergeLocalToProto();
  proto = viaProto ? proto : builder.build();
  viaProto = true;
  return proto;
}

项目：hadoop-2.6.0-cdh5.4.3 文件：ReservationRequestPBImpl.java

private void maybeInitBuilder() {
  if (viaProto || builder == null) {
    builder = ReservationRequestProto.newBuilder(proto);
  }
  viaProto = false;
}

项目：hops 文件：ReservationRequestsPBImpl.java

private ReservationRequestProto convertToProtoFormat(ReservationRequest r) {
  return ((ReservationRequestPBImpl) r).getProto();
}

项目：hops 文件：ReservationRequestsPBImpl.java

private ReservationRequestPBImpl convertFromProtoFormat(
    ReservationRequestProto r) {
  return new ReservationRequestPBImpl(r);
}

项目：hops 文件：ReservationRequestPBImpl.java

public ReservationRequestPBImpl() {
  builder = ReservationRequestProto.newBuilder();
}

项目：hops 文件：ReservationRequestPBImpl.java

public ReservationRequestPBImpl(ReservationRequestProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：hops 文件：ReservationRequestPBImpl.java

public ReservationRequestProto getProto() {
  mergeLocalToProto();
  proto = viaProto ? proto : builder.build();
  viaProto = true;
  return proto;
}

项目：hops 文件：ReservationRequestPBImpl.java

private void maybeInitBuilder() {
  if (viaProto || builder == null) {
    builder = ReservationRequestProto.newBuilder(proto);
  }
  viaProto = false;
}

org.apache.hadoop.yarn.proto.YarnProtos.ReservationRequestsProto的实例源码

项目：hadoop 文件：ReservationRequestsPBImpl.java

public ReservationRequestsPBImpl() {
  builder = ReservationRequestsProto.newBuilder();
}

项目：hadoop 文件：ReservationRequestsPBImpl.java

public ReservationRequestsPBImpl(ReservationRequestsProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：hadoop 文件：ReservationRequestsPBImpl.java

public ReservationRequestsProto getProto() {
  mergeLocalToProto();
  proto = viaProto ? proto : builder.build();
  viaProto = true;
  return proto;
}

项目：hadoop 文件：ReservationRequestsPBImpl.java

private void maybeInitBuilder() {
  if (viaProto || builder == null) {
    builder = ReservationRequestsProto.newBuilder(proto);
  }
  viaProto = false;
}

项目：hadoop 文件：ReservationDeFinitionPBImpl.java

private ReservationRequestsPBImpl convertFromProtoFormat(
    ReservationRequestsProto p) {
  return new ReservationRequestsPBImpl(p);
}

项目：hadoop 文件：ReservationDeFinitionPBImpl.java

private ReservationRequestsProto convertToProtoFormat(ReservationRequests t) {
  return ((ReservationRequestsPBImpl) t).getProto();
}

项目：aliyun-oss-hadoop-fs 文件：ReservationRequestsPBImpl.java

public ReservationRequestsPBImpl() {
  builder = ReservationRequestsProto.newBuilder();
}

项目：aliyun-oss-hadoop-fs 文件：ReservationRequestsPBImpl.java

public ReservationRequestsPBImpl(ReservationRequestsProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：aliyun-oss-hadoop-fs 文件：ReservationRequestsPBImpl.java

public ReservationRequestsProto getProto() {
  mergeLocalToProto();
  proto = viaProto ? proto : builder.build();
  viaProto = true;
  return proto;
}

项目：aliyun-oss-hadoop-fs 文件：ReservationRequestsPBImpl.java

private void maybeInitBuilder() {
  if (viaProto || builder == null) {
    builder = ReservationRequestsProto.newBuilder(proto);
  }
  viaProto = false;
}

项目：aliyun-oss-hadoop-fs 文件：ReservationDeFinitionPBImpl.java

private ReservationRequestsPBImpl convertFromProtoFormat(
    ReservationRequestsProto p) {
  return new ReservationRequestsPBImpl(p);
}

项目：aliyun-oss-hadoop-fs 文件：ReservationDeFinitionPBImpl.java

private ReservationRequestsProto convertToProtoFormat(ReservationRequests t) {
  return ((ReservationRequestsPBImpl) t).getProto();
}

项目：big-c 文件：ReservationRequestsPBImpl.java

public ReservationRequestsPBImpl() {
  builder = ReservationRequestsProto.newBuilder();
}

项目：big-c 文件：ReservationRequestsPBImpl.java

public ReservationRequestsPBImpl(ReservationRequestsProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：big-c 文件：ReservationRequestsPBImpl.java

public ReservationRequestsProto getProto() {
  mergeLocalToProto();
  proto = viaProto ? proto : builder.build();
  viaProto = true;
  return proto;
}

项目：big-c 文件：ReservationRequestsPBImpl.java

private void maybeInitBuilder() {
  if (viaProto || builder == null) {
    builder = ReservationRequestsProto.newBuilder(proto);
  }
  viaProto = false;
}

项目：big-c 文件：ReservationDeFinitionPBImpl.java

private ReservationRequestsPBImpl convertFromProtoFormat(
    ReservationRequestsProto p) {
  return new ReservationRequestsPBImpl(p);
}

项目：big-c 文件：ReservationDeFinitionPBImpl.java

private ReservationRequestsProto convertToProtoFormat(ReservationRequests t) {
  return ((ReservationRequestsPBImpl) t).getProto();
}

项目：hadoop-2.6.0-cdh5.4.3 文件：ReservationRequestsPBImpl.java

public ReservationRequestsPBImpl() {
  builder = ReservationRequestsProto.newBuilder();
}

项目：hadoop-2.6.0-cdh5.4.3 文件：ReservationRequestsPBImpl.java

public ReservationRequestsPBImpl(ReservationRequestsProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：hadoop-2.6.0-cdh5.4.3 文件：ReservationRequestsPBImpl.java

public ReservationRequestsProto getProto() {
  mergeLocalToProto();
  proto = viaProto ? proto : builder.build();
  viaProto = true;
  return proto;
}

项目：hadoop-2.6.0-cdh5.4.3 文件：ReservationRequestsPBImpl.java

private void maybeInitBuilder() {
  if (viaProto || builder == null) {
    builder = ReservationRequestsProto.newBuilder(proto);
  }
  viaProto = false;
}

项目：hadoop-2.6.0-cdh5.4.3 文件：ReservationDeFinitionPBImpl.java

private ReservationRequestsPBImpl convertFromProtoFormat(
    ReservationRequestsProto p) {
  return new ReservationRequestsPBImpl(p);
}

项目：hadoop-2.6.0-cdh5.4.3 文件：ReservationDeFinitionPBImpl.java

private ReservationRequestsProto convertToProtoFormat(ReservationRequests t) {
  return ((ReservationRequestsPBImpl) t).getProto();
}

项目：hops 文件：ReservationRequestsPBImpl.java

public ReservationRequestsPBImpl() {
  builder = ReservationRequestsProto.newBuilder();
}

项目：hops 文件：ReservationRequestsPBImpl.java

public ReservationRequestsPBImpl(ReservationRequestsProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：hops 文件：ReservationRequestsPBImpl.java

public ReservationRequestsProto getProto() {
  mergeLocalToProto();
  proto = viaProto ? proto : builder.build();
  viaProto = true;
  return proto;
}

项目：hops 文件：ReservationRequestsPBImpl.java

private void maybeInitBuilder() {
  if (viaProto || builder == null) {
    builder = ReservationRequestsProto.newBuilder(proto);
  }
  viaProto = false;
}

项目：hops 文件：ReservationDeFinitionPBImpl.java

private ReservationRequestsPBImpl convertFromProtoFormat(
    ReservationRequestsProto p) {
  return new ReservationRequestsPBImpl(p);
}

项目：hops 文件：ReservationDeFinitionPBImpl.java

private ReservationRequestsProto convertToProtoFormat(ReservationRequests t) {
  return ((ReservationRequestsPBImpl) t).getProto();
}

关于org.apache.hadoop.yarn.proto.YarnServiceProtos.MoveApplicationAcrossQueuesRequestProto的实例源码的介绍已经告一段落，感谢您的耐心阅读，如果想了解更多关于org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesRequest的实例源码、org.apache.hadoop.yarn.proto.YarnProtos.ApplicationAccessTypeProto的实例源码、org.apache.hadoop.yarn.proto.YarnProtos.ReservationRequestProto的实例源码、org.apache.hadoop.yarn.proto.YarnProtos.ReservationRequestsProto的实例源码的相关信息，请在本站寻找。

本文标签：