Java 类org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CreateSymlinkRequestProto 实例源码

@Override
public void createSymlink(String target, String link, FsPermission dirPerm,
    boolean createParent) throws AccessControlException,
    FileAlreadyExistsException, FileNotFoundException,
    ParentNotDirectoryException, SafeModeException, UnresolvedLinkException,
    IOException {
  CreateSymlinkRequestProto req = CreateSymlinkRequestProto.newBuilder()
      .setTarget(target)
      .setLink(link)
      .setDirPerm(PBHelper.convert(dirPerm))
      .setCreateParent(createParent)
      .build();
  try {
    rpcProxy.createSymlink(null, req);
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public void createSymlink(String target, String link, FsPermission dirPerm,
    boolean createParent) throws AccessControlException,
    FileAlreadyExistsException, FileNotFoundException,
    ParentNotDirectoryException, SafeModeException, UnresolvedLinkException,
    IOException {
  CreateSymlinkRequestProto req = CreateSymlinkRequestProto.newBuilder()
      .setTarget(target)
      .setLink(link)
      .setDirPerm(PBHelper.convert(dirPerm))
      .setCreateParent(createParent)
      .build();
  try {
    rpcProxy.createSymlink(null, req);
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public void createSymlink(String target, String link, FsPermission dirPerm,
    boolean createParent) throws AccessControlException,
    FileAlreadyExistsException, FileNotFoundException,
    ParentNotDirectoryException, SafeModeException, UnresolvedLinkException,
    IOException {
  CreateSymlinkRequestProto req = CreateSymlinkRequestProto.newBuilder()
      .setTarget(target)
      .setLink(link)
      .setDirPerm(PBHelper.convert(dirPerm))
      .setCreateParent(createParent)
      .build();
  try {
    rpcProxy.createSymlink(null, req);
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public void createSymlink(String target, String link, FsPermission dirPerm,
    boolean createParent) throws AccessControlException,
    FileAlreadyExistsException, FileNotFoundException,
    ParentNotDirectoryException, SafeModeException, UnresolvedLinkException,
    IOException {
  CreateSymlinkRequestProto req = CreateSymlinkRequestProto.newBuilder()
      .setTarget(target)
      .setLink(link)
      .setDirPerm(PBHelper.convert(dirPerm))
      .setCreateParent(createParent)
      .build();
  try {
    rpcProxy.createSymlink(null, req);
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public void createSymlink(String target, String link, FsPermission dirPerm,
    boolean createParent) throws AccessControlException,
    FileAlreadyExistsException, FileNotFoundException,
    ParentNotDirectoryException, SafeModeException, UnresolvedLinkException,
    IOException {
  CreateSymlinkRequestProto req = CreateSymlinkRequestProto.newBuilder()
      .setTarget(target)
      .setLink(link)
      .setDirPerm(PBHelper.convert(dirPerm))
      .setCreateParent(createParent)
      .build();
  try {
    rpcProxy.createSymlink(null, req);
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public void createSymlink(String target, String link, FsPermission dirPerm,
    boolean createParent)
    throws AccessControlException, FileAlreadyExistsException,
    FileNotFoundException, ParentNotDirectoryException, SafeModeException,
    UnresolvedLinkException, IOException {
  CreateSymlinkRequestProto req =
      CreateSymlinkRequestProto.newBuilder().setTarget(target).setLink(link)
          .setDirPerm(PBHelper.convert(dirPerm)).setCreateParent(createParent)
          .build();
  try {
    rpcProxy.createSymlink(null, req);
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public void createSymlink(String target, String link, FsPermission dirPerm,
    boolean createParent) throws AccessControlException,
    FileAlreadyExistsException, FileNotFoundException,
    ParentNotDirectoryException, SafeModeException, UnresolvedLinkException,
    IOException {
  CreateSymlinkRequestProto req = CreateSymlinkRequestProto.newBuilder()
      .setTarget(target)
      .setLink(link)
      .setDirPerm(PBHelper.convert(dirPerm))
      .setCreateParent(createParent)
      .build();
  try {
    rpcProxy.createSymlink(null, req);
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public void createSymlink(String target, String link, FsPermission dirPerm,
    boolean createParent) throws AccessControlException,
    FileAlreadyExistsException, FileNotFoundException,
    ParentNotDirectoryException, SafeModeException, UnresolvedLinkException,
    IOException {
  CreateSymlinkRequestProto req = CreateSymlinkRequestProto.newBuilder()
      .setTarget(target)
      .setLink(link)
      .setDirPerm(PBHelper.convert(dirPerm))
      .setCreateParent(createParent)
      .build();
  try {
    rpcProxy.createSymlink(null, req);
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public void createSymlink(String target, String link, FsPermission dirPerm,
    boolean createParent) throws AccessControlException,
    FileAlreadyExistsException, FileNotFoundException,
    ParentNotDirectoryException, SafeModeException, UnresolvedLinkException,
    IOException {
  CreateSymlinkRequestProto req = CreateSymlinkRequestProto.newBuilder()
      .setTarget(target)
      .setLink(link)
      .setDirPerm(PBHelper.convert(dirPerm))
      .setCreateParent(createParent)
      .build();
  try {
    rpcProxy.createSymlink(null, req);
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public CreateSymlinkResponseProto createSymlink(RpcController controller,
    CreateSymlinkRequestProto req) throws ServiceException {
  try {
    server.createSymlink(req.getTarget(), req.getLink(),
        PBHelper.convert(req.getDirPerm()), req.getCreateParent());
    return VOID_CREATESYMLINK_RESPONSE;
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public void createSymlink(String target, String link, FsPermission dirPerm,
    boolean createParent) throws IOException {
  CreateSymlinkRequestProto req = CreateSymlinkRequestProto.newBuilder()
      .setTarget(target)
      .setLink(link)
      .setDirPerm(PBHelperClient.convert(dirPerm))
      .setCreateParent(createParent)
      .build();
  try {
    rpcProxy.createSymlink(null, req);
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public CreateSymlinkResponseProto createSymlink(RpcController controller,
    CreateSymlinkRequestProto req) throws ServiceException {
  try {
    server.createSymlink(req.getTarget(), req.getLink(),
        PBHelperClient.convert(req.getDirPerm()), req.getCreateParent());
    return VOID_CREATESYMLINK_RESPONSE;
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public CreateSymlinkResponseProto createSymlink(RpcController controller,
    CreateSymlinkRequestProto req) throws ServiceException {
  try {
    server.createSymlink(req.getTarget(), req.getLink(),
        PBHelper.convert(req.getDirPerm()), req.getCreateParent());
    return VOID_CREATESYMLINK_RESPONSE;
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public CreateSymlinkResponseProto createSymlink(RpcController controller,
    CreateSymlinkRequestProto req) throws ServiceException {
  try {
    server.createSymlink(req.getTarget(), req.getLink(),
        PBHelper.convert(req.getDirPerm()), req.getCreateParent());
    return VOID_CREATESYMLINK_RESPONSE;
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public CreateSymlinkResponseProto createSymlink(RpcController controller,
    CreateSymlinkRequestProto req) throws ServiceException {
  try {
    server.createSymlink(req.getTarget(), req.getLink(),
        PBHelper.convert(req.getDirPerm()), req.getCreateParent());
    return VOID_CREATESYMLINK_RESPONSE;
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public CreateSymlinkResponseProto createSymlink(RpcController controller,
    CreateSymlinkRequestProto req) throws ServiceException {
  try {
    server.createSymlink(req.getTarget(), req.getLink(),
        PBHelper.convert(req.getDirPerm()), req.getCreateParent());
    return VOID_CREATESYMLINK_RESPONSE;
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public CreateSymlinkResponseProto createSymlink(RpcController controller,
    CreateSymlinkRequestProto req) throws ServiceException {
  try {
    server.createSymlink(req.getTarget(), req.getLink(),
        PBHelper.convert(req.getDirPerm()), req.getCreateParent());
    return VOID_CREATESYMLINK_RESPONSE;
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public CreateSymlinkResponseProto createSymlink(RpcController controller,
    CreateSymlinkRequestProto req) throws ServiceException {
  try {
    server.createSymlink(req.getTarget(), req.getLink(),
        PBHelper.convert(req.getDirPerm()), req.getCreateParent());
    return VOID_CREATESYMLINK_RESPONSE;
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public CreateSymlinkResponseProto createSymlink(RpcController controller,
    CreateSymlinkRequestProto req) throws ServiceException {
  try {
    server.createSymlink(req.getTarget(), req.getLink(),
        PBHelper.convert(req.getDirPerm()), req.getCreateParent());
    return VOID_CREATESYMLINK_RESPONSE;
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public CreateSymlinkResponseProto createSymlink(RpcController controller,
    CreateSymlinkRequestProto req) throws ServiceException {
  try {
    server.createSymlink(req.getTarget(), req.getLink(),
        PBHelper.convert(req.getDirPerm()), req.getCreateParent());
    return VOID_CREATESYMLINK_RESPONSE;
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}