Java 类org.apache.hadoop.yarn.api.protocolrecords.impl.pb.UseSharedCacheResourceResponsePBImpl 实例源码

@Override
public UseSharedCacheResourceResponse use(
    UseSharedCacheResourceRequest request) throws YarnException, IOException {
  UseSharedCacheResourceRequestProto requestProto =
      ((UseSharedCacheResourceRequestPBImpl) request).getProto();
  try {
    return new UseSharedCacheResourceResponsePBImpl(proxy.use(null,
        requestProto));
  } catch (ServiceException e) {
    RPCUtil.unwrapAndThrowException(e);
    return null;
  }
}

@Test
public void testUse() throws Exception {
  Path file = new Path("viewfs://test/path");
  UseSharedCacheResourceResponse response =
      new UseSharedCacheResourceResponsePBImpl();
  response.setPath(file.toString());
  when(cProtocol.use(isA(UseSharedCacheResourceRequest.class))).thenReturn(
      response);
  Path newPath = client.use(mock(ApplicationId.class), "key");
  assertEquals(file, newPath);
}

@Override
public UseSharedCacheResourceResponse use(
    UseSharedCacheResourceRequest request) throws YarnException, IOException {
  UseSharedCacheResourceRequestProto requestProto =
      ((UseSharedCacheResourceRequestPBImpl) request).getProto();
  try {
    return new UseSharedCacheResourceResponsePBImpl(proxy.use(null,
        requestProto));
  } catch (ServiceException e) {
    RPCUtil.unwrapAndThrowException(e);
    return null;
  }
}

@Test
public void testUse() throws Exception {
  Path file = new Path("viewfs://test/path");
  UseSharedCacheResourceResponse response =
      new UseSharedCacheResourceResponsePBImpl();
  response.setPath(file.toString());
  when(cProtocol.use(isA(UseSharedCacheResourceRequest.class))).thenReturn(
      response);
  Path newPath = client.use(mock(ApplicationId.class), "key");
  assertEquals(file, newPath);
}

@Override
public UseSharedCacheResourceResponse use(
    UseSharedCacheResourceRequest request) throws YarnException, IOException {
  UseSharedCacheResourceRequestProto requestProto =
      ((UseSharedCacheResourceRequestPBImpl) request).getProto();
  try {
    return new UseSharedCacheResourceResponsePBImpl(proxy.use(null,
        requestProto));
  } catch (ServiceException e) {
    RPCUtil.unwrapAndThrowException(e);
    return null;
  }
}

@Test
public void testUse() throws Exception {
  Path file = new Path("viewfs://test/path");
  UseSharedCacheResourceResponse response =
      new UseSharedCacheResourceResponsePBImpl();
  response.setPath(file.toString());
  when(cProtocol.use(isA(UseSharedCacheResourceRequest.class))).thenReturn(
      response);
  Path newPath = client.use(mock(ApplicationId.class), "key");
  assertEquals(file, newPath);
}

@Override
public UseSharedCacheResourceResponse use(
    UseSharedCacheResourceRequest request) throws YarnException, IOException {
  UseSharedCacheResourceRequestProto requestProto =
      ((UseSharedCacheResourceRequestPBImpl) request).getProto();
  try {
    return new UseSharedCacheResourceResponsePBImpl(proxy.use(null,
        requestProto));
  } catch (ServiceException e) {
    RPCUtil.unwrapAndThrowException(e);
    return null;
  }
}

@Test
public void testUse() throws Exception {
  Path file = new Path("viewfs://test/path");
  UseSharedCacheResourceResponse response =
      new UseSharedCacheResourceResponsePBImpl();
  response.setPath(file.toString());
  when(cProtocol.use(isA(UseSharedCacheResourceRequest.class))).thenReturn(
      response);
  Path newPath = client.use(mock(ApplicationId.class), "key");
  assertEquals(file, newPath);
}