@Override public GetFileLinkInfoResponseProto getFileLinkInfo(RpcController controller, GetFileLinkInfoRequestProto req) throws ServiceException { try { HdfsFileStatus result = server.getFileLinkInfo(req.getSrc()); if (result != null) { return GetFileLinkInfoResponseProto.newBuilder().setFs( PBHelper.convert(result)).build(); } else { return VOID_GETFILELINKINFO_RESPONSE; } } catch (IOException e) { throw new ServiceException(e); } }
@Override public GetFileLinkInfoResponseProto getFileLinkInfo(RpcController controller, GetFileLinkInfoRequestProto req) throws ServiceException { try { HdfsFileStatus result = server.getFileLinkInfo(req.getSrc()); if (result != null) { return GetFileLinkInfoResponseProto.newBuilder().setFs( PBHelperClient.convert(result)).build(); } else { return VOID_GETFILELINKINFO_RESPONSE; } } catch (IOException e) { throw new ServiceException(e); } }
@Override public GetFileLinkInfoResponseProto getFileLinkInfo(RpcController controller, GetFileLinkInfoRequestProto req) throws ServiceException { try { HdfsFileStatus result = server.getFileLinkInfo(req.getSrc()); if (result != null) { System.out.println("got non null result for getFileLinkInfo for " + req.getSrc()); return GetFileLinkInfoResponseProto.newBuilder().setFs( PBHelper.convert(result)).build(); } else { System.out.println("got null result for getFileLinkInfo for " + req.getSrc()); return VOID_GETFILELINKINFO_RESPONSE; } } catch (IOException e) { throw new ServiceException(e); } }
@Override public GetFileLinkInfoResponseProto getFileLinkInfo(RpcController controller, GetFileLinkInfoRequestProto req) throws ServiceException { try { HdfsFileStatus result = server.getFileLinkInfo(req.getSrc()); if (result != null) { System.out.println( "got non null result for getFileLinkInfo for " + req.getSrc()); return GetFileLinkInfoResponseProto.newBuilder() .setFs(PBHelper.convert(result)).build(); } else { System.out.println( "got null result for getFileLinkInfo for " + req.getSrc()); return VOID_GETFILELINKINFO_RESPONSE; } } catch (IOException e) { throw new ServiceException(e); } }
@Override public HdfsFileStatus getFileLinkInfo(String src) throws AccessControlException, UnresolvedLinkException, IOException { GetFileLinkInfoRequestProto req = GetFileLinkInfoRequestProto.newBuilder() .setSrc(src).build(); try { GetFileLinkInfoResponseProto result = rpcProxy.getFileLinkInfo(null, req); return result.hasFs() ? PBHelper.convert(rpcProxy.getFileLinkInfo(null, req).getFs()) : null; } catch (ServiceException e) { throw ProtobufHelper.getRemoteException(e); } }
@Override public HdfsFileStatus getFileLinkInfo(String src) throws IOException { GetFileLinkInfoRequestProto req = GetFileLinkInfoRequestProto.newBuilder() .setSrc(src).build(); try { GetFileLinkInfoResponseProto result = rpcProxy.getFileLinkInfo(null, req); return result.hasFs() ? PBHelperClient.convert(rpcProxy.getFileLinkInfo(null, req).getFs()) : null; } catch (ServiceException e) { throw ProtobufHelper.getRemoteException(e); } }
@Override public HdfsFileStatus getFileLinkInfo(String src) throws AccessControlException, UnresolvedLinkException, IOException { GetFileLinkInfoRequestProto req = GetFileLinkInfoRequestProto.newBuilder().setSrc(src).build(); try { GetFileLinkInfoResponseProto result = rpcProxy.getFileLinkInfo(null, req); return result.hasFs() ? PBHelper.convert(rpcProxy.getFileLinkInfo(null, req).getFs()) : null; } catch (ServiceException e) { throw ProtobufHelper.getRemoteException(e); } }