1. 包列表
  2. 类列表
  3. org.apache.hadoop.fs.http.server.HttpFSParametersProvider.OperationParam

Java 类org.apache.hadoop.fs.http.server.HttpFSParametersProvider.OperationParam 实例源码

项目：hadoop    文件：HttpFSServer.java    
/**
 * Binding to handle DELETE requests.
 *
 * @param path the path for operation.
 * @param op the HttpFS operation of the request.
 * @param params the HttpFS parameters of the request.
 *
 * @return the request response.
 *
 * @throws IOException thrown if an IO error occurred. Thrown exceptions are
 * handled by {@link HttpFSExceptionProvider}.
 * @throws FileSystemAccessException thrown if a FileSystemAccess releated
 * error occurred. Thrown exceptions are handled by
 * {@link HttpFSExceptionProvider}.
 */
@DELETE
@Path("{path:.*}")
@Produces(MediaType.APPLICATION_JSON)
public Response delete(@PathParam("path") String path,
                       @QueryParam(OperationParam.NAME) OperationParam op,
                       @Context Parameters params,
                       @Context HttpServletRequest request)
  throws IOException, FileSystemAccessException {
  UserGroupInformation user = HttpUserGroupInformation.get();
  Response response;
  path = makeAbsolute(path);
  MDC.put(HttpFSFileSystem.OP_PARAM, op.value().name());
  MDC.put("hostname", request.getRemoteAddr());
  switch (op.value()) {
    case DELETE: {
      Boolean recursive =
        params.get(RecursiveParam.NAME,  RecursiveParam.class);
      AUDIT_LOG.info("[{}] recursive [{}]", path, recursive);
      FSOperations.FSDelete command =
        new FSOperations.FSDelete(path, recursive);
      JSONObject json = fsExecute(user, command);
      response = Response.ok(json).type(MediaType.APPLICATION_JSON).build();
      break;
    }
    default: {
      throw new IOException(
        MessageFormat.format("Invalid HTTP DELETE operation [{0}]",
                             op.value()));
    }
  }
  return response;
}
项目：aliyun-oss-hadoop-fs    文件：HttpFSServer.java    
/**
 * Binding to handle DELETE requests.
 *
 * @param path the path for operation.
 * @param op the HttpFS operation of the request.
 * @param params the HttpFS parameters of the request.
 *
 * @return the request response.
 *
 * @throws IOException thrown if an IO error occurred. Thrown exceptions are
 * handled by {@link HttpFSExceptionProvider}.
 * @throws FileSystemAccessException thrown if a FileSystemAccess releated
 * error occurred. Thrown exceptions are handled by
 * {@link HttpFSExceptionProvider}.
 */
@DELETE
@Path("{path:.*}")
@Produces(MediaType.APPLICATION_JSON)
public Response delete(@PathParam("path") String path,
                       @QueryParam(OperationParam.NAME) OperationParam op,
                       @Context Parameters params,
                       @Context HttpServletRequest request)
  throws IOException, FileSystemAccessException {
  UserGroupInformation user = HttpUserGroupInformation.get();
  Response response;
  path = makeAbsolute(path);
  MDC.put(HttpFSFileSystem.OP_PARAM, op.value().name());
  MDC.put("hostname", request.getRemoteAddr());
  switch (op.value()) {
    case DELETE: {
      Boolean recursive =
        params.get(RecursiveParam.NAME,  RecursiveParam.class);
      AUDIT_LOG.info("[{}] recursive [{}]", path, recursive);
      FSOperations.FSDelete command =
        new FSOperations.FSDelete(path, recursive);
      JSONObject json = fsExecute(user, command);
      response = Response.ok(json).type(MediaType.APPLICATION_JSON).build();
      break;
    }
    default: {
      throw new IOException(
        MessageFormat.format("Invalid HTTP DELETE operation [{0}]",
                             op.value()));
    }
  }
  return response;
}
项目：big-c    文件：HttpFSServer.java    
/**
 * Binding to handle DELETE requests.
 *
 * @param path the path for operation.
 * @param op the HttpFS operation of the request.
 * @param params the HttpFS parameters of the request.
 *
 * @return the request response.
 *
 * @throws IOException thrown if an IO error occurred. Thrown exceptions are
 * handled by {@link HttpFSExceptionProvider}.
 * @throws FileSystemAccessException thrown if a FileSystemAccess releated
 * error occurred. Thrown exceptions are handled by
 * {@link HttpFSExceptionProvider}.
 */
@DELETE
@Path("{path:.*}")
@Produces(MediaType.APPLICATION_JSON)
public Response delete(@PathParam("path") String path,
                       @QueryParam(OperationParam.NAME) OperationParam op,
                       @Context Parameters params,
                       @Context HttpServletRequest request)
  throws IOException, FileSystemAccessException {
  UserGroupInformation user = HttpUserGroupInformation.get();
  Response response;
  path = makeAbsolute(path);
  MDC.put(HttpFSFileSystem.OP_PARAM, op.value().name());
  MDC.put("hostname", request.getRemoteAddr());
  switch (op.value()) {
    case DELETE: {
      Boolean recursive =
        params.get(RecursiveParam.NAME,  RecursiveParam.class);
      AUDIT_LOG.info("[{}] recursive [{}]", path, recursive);
      FSOperations.FSDelete command =
        new FSOperations.FSDelete(path, recursive);
      JSONObject json = fsExecute(user, command);
      response = Response.ok(json).type(MediaType.APPLICATION_JSON).build();
      break;
    }
    default: {
      throw new IOException(
        MessageFormat.format("Invalid HTTP DELETE operation [{0}]",
                             op.value()));
    }
  }
  return response;
}
项目：hadoop-2.6.0-cdh5.4.3    文件：HttpFSServer.java    
/**
 * Binding to handle DELETE requests.
 *
 * @param path the path for operation.
 * @param op the HttpFS operation of the request.
 * @param params the HttpFS parameters of the request.
 *
 * @return the request response.
 *
 * @throws IOException thrown if an IO error occurred. Thrown exceptions are
 * handled by {@link HttpFSExceptionProvider}.
 * @throws FileSystemAccessException thrown if a FileSystemAccess releated
 * error occurred. Thrown exceptions are handled by
 * {@link HttpFSExceptionProvider}.
 */
@DELETE
@Path("{path:.*}")
@Produces(MediaType.APPLICATION_JSON)
public Response delete(@PathParam("path") String path,
                       @QueryParam(OperationParam.NAME) OperationParam op,
                       @Context Parameters params)
  throws IOException, FileSystemAccessException {
  UserGroupInformation user = HttpUserGroupInformation.get();
  Response response;
  path = makeAbsolute(path);
  MDC.put(HttpFSFileSystem.OP_PARAM, op.value().name());
  switch (op.value()) {
    case DELETE: {
      Boolean recursive =
        params.get(RecursiveParam.NAME,  RecursiveParam.class);
      AUDIT_LOG.info("[{}] recursive [{}]", path, recursive);
      FSOperations.FSDelete command =
        new FSOperations.FSDelete(path, recursive);
      JSONObject json = fsExecute(user, command);
      response = Response.ok(json).type(MediaType.APPLICATION_JSON).build();
      break;
    }
    default: {
      throw new IOException(
        MessageFormat.format("Invalid HTTP DELETE operation [{0}]",
                             op.value()));
    }
  }
  return response;
}
项目：hadoop-plus    文件：HttpFSServer.java    
/**
 * Binding to handle DELETE requests.
 *
 * @param user the principal of the user making the request.
 * @param path the path for operation.
 * @param op the HttpFS operation of the request.
 * @param params the HttpFS parameters of the request.
 *
 * @return the request response.
 *
 * @throws IOException thrown if an IO error occurred. Thrown exceptions are
 * handled by {@link HttpFSExceptionProvider}.
 * @throws FileSystemAccessException thrown if a FileSystemAccess releated
 * error occurred. Thrown exceptions are handled by
 * {@link HttpFSExceptionProvider}.
 */
@DELETE
@Path("{path:.*}")
@Produces(MediaType.APPLICATION_JSON)
public Response delete(@Context Principal user,
                    @PathParam("path") String path,
                    @QueryParam(OperationParam.NAME) OperationParam op,
                    @Context Parameters params)
  throws IOException, FileSystemAccessException {
  Response response;
  path = makeAbsolute(path);
  MDC.put(HttpFSFileSystem.OP_PARAM, op.value().name());
  String doAs = params.get(DoAsParam.NAME, DoAsParam.class);
  switch (op.value()) {
    case DELETE: {
      Boolean recursive =
        params.get(RecursiveParam.NAME,  RecursiveParam.class);
      AUDIT_LOG.info("[{}] recursive [{}]", path, recursive);
      FSOperations.FSDelete command =
        new FSOperations.FSDelete(path, recursive);
      JSONObject json = fsExecute(user, doAs, command);
      response = Response.ok(json).type(MediaType.APPLICATION_JSON).build();
      break;
    }
    default: {
      throw new IOException(
        MessageFormat.format("Invalid HTTP DELETE operation [{0}]",
                             op.value()));
    }
  }
  return response;
}
项目：hops    文件：HttpFSServer.java    
/**
 * Binding to handle DELETE requests.
 *
 * @param user
 *     the principal of the user making the request.
 * @param path
 *     the path for operation.
 * @param op
 *     the HttpFS operation of the request.
 * @param params
 *     the HttpFS parameters of the request.
 * @return the request response.
 * @throws IOException
 *     thrown if an IO error occurred. Thrown exceptions are
 *     handled by {@link HttpFSExceptionProvider}.
 * @throws FileSystemAccessException
 *     thrown if a FileSystemAccess releated
 *     error occurred. Thrown exceptions are handled by
 *     {@link HttpFSExceptionProvider}.
 */
@DELETE
@Path("{path:.*}")
@Produces(MediaType.APPLICATION_JSON)
public Response delete(
    @Context
    Principal user,
    @PathParam("path")
    String path,
    @QueryParam(OperationParam.NAME)
    OperationParam op,
    @Context
    Parameters params) throws IOException, FileSystemAccessException {
  Response response;
  path = makeAbsolute(path);
  MDC.put(HttpFSFileSystem.OP_PARAM, op.value().name());
  String doAs = params.get(DoAsParam.NAME, DoAsParam.class);
  switch (op.value()) {
    case DELETE: {
      Boolean recursive =
          params.get(RecursiveParam.NAME, RecursiveParam.class);
      AUDIT_LOG.info("[{}] recursive [{}]", path, recursive);
      FSOperations.FSDelete command =
          new FSOperations.FSDelete(path, recursive);
      JSONObject json = fsExecute(user, doAs, command);
      response = Response.ok(json).type(MediaType.APPLICATION_JSON).build();
      break;
    }
    default: {
      throw new IOException(MessageFormat
          .format("Invalid HTTP DELETE operation [{0}]", op.value()));
    }
  }
  return response;
}
项目：hadoop-TCP    文件：HttpFSServer.java    
/**
 * Binding to handle DELETE requests.
 *
 * @param user the principal of the user making the request.
 * @param path the path for operation.
 * @param op the HttpFS operation of the request.
 * @param params the HttpFS parameters of the request.
 *
 * @return the request response.
 *
 * @throws IOException thrown if an IO error occurred. Thrown exceptions are
 * handled by {@link HttpFSExceptionProvider}.
 * @throws FileSystemAccessException thrown if a FileSystemAccess releated
 * error occurred. Thrown exceptions are handled by
 * {@link HttpFSExceptionProvider}.
 */
@DELETE
@Path("{path:.*}")
@Produces(MediaType.APPLICATION_JSON)
public Response delete(@Context Principal user,
                    @PathParam("path") String path,
                    @QueryParam(OperationParam.NAME) OperationParam op,
                    @Context Parameters params)
  throws IOException, FileSystemAccessException {
  Response response;
  path = makeAbsolute(path);
  MDC.put(HttpFSFileSystem.OP_PARAM, op.value().name());
  String doAs = params.get(DoAsParam.NAME, DoAsParam.class);
  switch (op.value()) {
    case DELETE: {
      Boolean recursive =
        params.get(RecursiveParam.NAME,  RecursiveParam.class);
      AUDIT_LOG.info("[{}] recursive [{}]", path, recursive);
      FSOperations.FSDelete command =
        new FSOperations.FSDelete(path, recursive);
      JSONObject json = fsExecute(user, doAs, command);
      response = Response.ok(json).type(MediaType.APPLICATION_JSON).build();
      break;
    }
    default: {
      throw new IOException(
        MessageFormat.format("Invalid HTTP DELETE operation [{0}]",
                             op.value()));
    }
  }
  return response;
}
项目：hardfs    文件：HttpFSServer.java    
/**
 * Binding to handle DELETE requests.
 *
 * @param user the principal of the user making the request.
 * @param path the path for operation.
 * @param op the HttpFS operation of the request.
 * @param params the HttpFS parameters of the request.
 *
 * @return the request response.
 *
 * @throws IOException thrown if an IO error occurred. Thrown exceptions are
 * handled by {@link HttpFSExceptionProvider}.
 * @throws FileSystemAccessException thrown if a FileSystemAccess releated
 * error occurred. Thrown exceptions are handled by
 * {@link HttpFSExceptionProvider}.
 */
@DELETE
@Path("{path:.*}")
@Produces(MediaType.APPLICATION_JSON)
public Response delete(@Context Principal user,
                    @PathParam("path") String path,
                    @QueryParam(OperationParam.NAME) OperationParam op,
                    @Context Parameters params)
  throws IOException, FileSystemAccessException {
  Response response;
  path = makeAbsolute(path);
  MDC.put(HttpFSFileSystem.OP_PARAM, op.value().name());
  String doAs = params.get(DoAsParam.NAME, DoAsParam.class);
  switch (op.value()) {
    case DELETE: {
      Boolean recursive =
        params.get(RecursiveParam.NAME,  RecursiveParam.class);
      AUDIT_LOG.info("[{}] recursive [{}]", path, recursive);
      FSOperations.FSDelete command =
        new FSOperations.FSDelete(path, recursive);
      JSONObject json = fsExecute(user, doAs, command);
      response = Response.ok(json).type(MediaType.APPLICATION_JSON).build();
      break;
    }
    default: {
      throw new IOException(
        MessageFormat.format("Invalid HTTP DELETE operation [{0}]",
                             op.value()));
    }
  }
  return response;
}
项目：hadoop-on-lustre2    文件：HttpFSServer.java    
/**
 * Binding to handle DELETE requests.
 *
 * @param user the principal of the user making the request.
 * @param path the path for operation.
 * @param op the HttpFS operation of the request.
 * @param params the HttpFS parameters of the request.
 *
 * @return the request response.
 *
 * @throws IOException thrown if an IO error occurred. Thrown exceptions are
 * handled by {@link HttpFSExceptionProvider}.
 * @throws FileSystemAccessException thrown if a FileSystemAccess releated
 * error occurred. Thrown exceptions are handled by
 * {@link HttpFSExceptionProvider}.
 */
@DELETE
@Path("{path:.*}")
@Produces(MediaType.APPLICATION_JSON)
public Response delete(@Context Principal user,
                    @PathParam("path") String path,
                    @QueryParam(OperationParam.NAME) OperationParam op,
                    @Context Parameters params)
  throws IOException, FileSystemAccessException {
  Response response;
  path = makeAbsolute(path);
  MDC.put(HttpFSFileSystem.OP_PARAM, op.value().name());
  String doAs = params.get(DoAsParam.NAME, DoAsParam.class);
  switch (op.value()) {
    case DELETE: {
      Boolean recursive =
        params.get(RecursiveParam.NAME,  RecursiveParam.class);
      AUDIT_LOG.info("[{}] recursive [{}]", path, recursive);
      FSOperations.FSDelete command =
        new FSOperations.FSDelete(path, recursive);
      JSONObject json = fsExecute(user, doAs, command);
      response = Response.ok(json).type(MediaType.APPLICATION_JSON).build();
      break;
    }
    default: {
      throw new IOException(
        MessageFormat.format("Invalid HTTP DELETE operation [{0}]",
                             op.value()));
    }
  }
  return response;
}
项目：hadoop    文件：HttpFSServer.java    
/**
 * Special binding for '/' as it is not handled by the wildcard binding.
 *
 * @param op the HttpFS operation of the request.
 * @param params the HttpFS parameters of the request.
 *
 * @return the request response.
 *
 * @throws IOException thrown if an IO error occurred. Thrown exceptions are
 * handled by {@link HttpFSExceptionProvider}.
 * @throws FileSystemAccessException thrown if a FileSystemAccess releated
 * error occurred. Thrown exceptions are handled by
 * {@link HttpFSExceptionProvider}.
 */
@GET
@Produces(MediaType.APPLICATION_JSON)
public Response getRoot(@QueryParam(OperationParam.NAME) OperationParam op,
                        @Context Parameters params,
                        @Context HttpServletRequest request)
  throws IOException, FileSystemAccessException {
  return get("", op, params, request);
}
项目：hadoop    文件：HttpFSServer.java    
/**
 * Creates the URL for an upload operation (create or append).
 *
 * @param uriInfo uri info of the request.
 * @param uploadOperation operation for the upload URL.
 *
 * @return the URI for uploading data.
 */
protected URI createUploadRedirectionURL(UriInfo uriInfo, Enum<?> uploadOperation) {
  UriBuilder uriBuilder = uriInfo.getRequestUriBuilder();
  uriBuilder = uriBuilder.replaceQueryParam(OperationParam.NAME, uploadOperation).
    queryParam(DataParam.NAME, Boolean.TRUE);
  return uriBuilder.build(null);
}
项目：aliyun-oss-hadoop-fs    文件：HttpFSServer.java    
/**
 * Special binding for '/' as it is not handled by the wildcard binding.
 *
 * @param op the HttpFS operation of the request.
 * @param params the HttpFS parameters of the request.
 *
 * @return the request response.
 *
 * @throws IOException thrown if an IO error occurred. Thrown exceptions are
 * handled by {@link HttpFSExceptionProvider}.
 * @throws FileSystemAccessException thrown if a FileSystemAccess releated
 * error occurred. Thrown exceptions are handled by
 * {@link HttpFSExceptionProvider}.
 */
@GET
@Produces(MediaType.APPLICATION_JSON)
public Response getRoot(@QueryParam(OperationParam.NAME) OperationParam op,
                        @Context Parameters params,
                        @Context HttpServletRequest request)
  throws IOException, FileSystemAccessException {
  return get("", op, params, request);
}
项目：aliyun-oss-hadoop-fs    文件：HttpFSServer.java    
/**
 * Creates the URL for an upload operation (create or append).
 *
 * @param uriInfo uri info of the request.
 * @param uploadOperation operation for the upload URL.
 *
 * @return the URI for uploading data.
 */
protected URI createUploadRedirectionURL(UriInfo uriInfo, Enum<?> uploadOperation) {
  UriBuilder uriBuilder = uriInfo.getRequestUriBuilder();
  uriBuilder = uriBuilder.replaceQueryParam(OperationParam.NAME, uploadOperation).
    queryParam(DataParam.NAME, Boolean.TRUE);
  return uriBuilder.build(null);
}
项目：big-c    文件：HttpFSServer.java    
/**
 * Special binding for '/' as it is not handled by the wildcard binding.
 *
 * @param op the HttpFS operation of the request.
 * @param params the HttpFS parameters of the request.
 *
 * @return the request response.
 *
 * @throws IOException thrown if an IO error occurred. Thrown exceptions are
 * handled by {@link HttpFSExceptionProvider}.
 * @throws FileSystemAccessException thrown if a FileSystemAccess releated
 * error occurred. Thrown exceptions are handled by
 * {@link HttpFSExceptionProvider}.
 */
@GET
@Produces(MediaType.APPLICATION_JSON)
public Response getRoot(@QueryParam(OperationParam.NAME) OperationParam op,
                        @Context Parameters params,
                        @Context HttpServletRequest request)
  throws IOException, FileSystemAccessException {
  return get("", op, params, request);
}
项目：big-c    文件：HttpFSServer.java    
/**
 * Creates the URL for an upload operation (create or append).
 *
 * @param uriInfo uri info of the request.
 * @param uploadOperation operation for the upload URL.
 *
 * @return the URI for uploading data.
 */
protected URI createUploadRedirectionURL(UriInfo uriInfo, Enum<?> uploadOperation) {
  UriBuilder uriBuilder = uriInfo.getRequestUriBuilder();
  uriBuilder = uriBuilder.replaceQueryParam(OperationParam.NAME, uploadOperation).
    queryParam(DataParam.NAME, Boolean.TRUE);
  return uriBuilder.build(null);
}
项目：hadoop-2.6.0-cdh5.4.3    文件：HttpFSServer.java    
/**
 * Special binding for '/' as it is not handled by the wildcard binding.
 *
 * @param op the HttpFS operation of the request.
 * @param params the HttpFS parameters of the request.
 *
 * @return the request response.
 *
 * @throws IOException thrown if an IO error occurred. Thrown exceptions are
 * handled by {@link HttpFSExceptionProvider}.
 * @throws FileSystemAccessException thrown if a FileSystemAccess releated
 * error occurred. Thrown exceptions are handled by
 * {@link HttpFSExceptionProvider}.
 */
@GET
@Produces(MediaType.APPLICATION_JSON)
public Response getRoot(@QueryParam(OperationParam.NAME) OperationParam op,
                        @Context Parameters params)
  throws IOException, FileSystemAccessException {
  return get("", op, params);
}
项目：hadoop-2.6.0-cdh5.4.3    文件：HttpFSServer.java    
/**
 * Creates the URL for an upload operation (create or append).
 *
 * @param uriInfo uri info of the request.
 * @param uploadOperation operation for the upload URL.
 *
 * @return the URI for uploading data.
 */
protected URI createUploadRedirectionURL(UriInfo uriInfo, Enum<?> uploadOperation) {
  UriBuilder uriBuilder = uriInfo.getRequestUriBuilder();
  uriBuilder = uriBuilder.replaceQueryParam(OperationParam.NAME, uploadOperation).
    queryParam(DataParam.NAME, Boolean.TRUE);
  return uriBuilder.build(null);
}
项目：hadoop-plus    文件：HttpFSServer.java    
/**
 * Special binding for '/' as it is not handled by the wildcard binding.
 *
 * @param user the principal of the user making the request.
 * @param op the HttpFS operation of the request.
 * @param params the HttpFS parameters of the request.
 *
 * @return the request response.
 *
 * @throws IOException thrown if an IO error occurred. Thrown exceptions are
 * handled by {@link HttpFSExceptionProvider}.
 * @throws FileSystemAccessException thrown if a FileSystemAccess releated
 * error occurred. Thrown exceptions are handled by
 * {@link HttpFSExceptionProvider}.
 */
@GET
@Produces(MediaType.APPLICATION_JSON)
public Response getRoot(@Context Principal user,
                        @QueryParam(OperationParam.NAME) OperationParam op,
                        @Context Parameters params)
  throws IOException, FileSystemAccessException {
  return get(user, "", op, params);
}
项目：hadoop-plus    文件：HttpFSServer.java    
/**
 * Creates the URL for an upload operation (create or append).
 *
 * @param uriInfo uri info of the request.
 * @param uploadOperation operation for the upload URL.
 *
 * @return the URI for uploading data.
 */
protected URI createUploadRedirectionURL(UriInfo uriInfo, Enum<?> uploadOperation) {
  UriBuilder uriBuilder = uriInfo.getRequestUriBuilder();
  uriBuilder = uriBuilder.replaceQueryParam(OperationParam.NAME, uploadOperation).
    queryParam(DataParam.NAME, Boolean.TRUE);
  return uriBuilder.build(null);
}
项目：hops    文件：HttpFSServer.java    
/**
 * Special binding for '/' as it is not handled by the wildcard binding.
 *
 * @param user
 *     the principal of the user making the request.
 * @param op
 *     the HttpFS operation of the request.
 * @param params
 *     the HttpFS parameters of the request.
 * @return the request response.
 * @throws IOException
 *     thrown if an IO error occurred. Thrown exceptions are
 *     handled by {@link HttpFSExceptionProvider}.
 * @throws FileSystemAccessException
 *     thrown if a FileSystemAccess releated
 *     error occurred. Thrown exceptions are handled by
 *     {@link HttpFSExceptionProvider}.
 */
@GET
@Path("/")
@Produces(MediaType.APPLICATION_JSON)
public Response getRoot(
    @Context
    Principal user,
    @QueryParam(OperationParam.NAME)
    OperationParam op,
    @Context
    Parameters params) throws IOException, FileSystemAccessException {
  return get(user, "", op, params);
}
项目：hops    文件：HttpFSServer.java    
/**
 * Creates the URL for an upload operation (create or append).
 *
 * @param uriInfo
 *     uri info of the request.
 * @param uploadOperation
 *     operation for the upload URL.
 * @return the URI for uploading data.
 */
protected URI createUploadRedirectionURL(UriInfo uriInfo,
    Enum<?> uploadOperation) {
  UriBuilder uriBuilder = uriInfo.getRequestUriBuilder();
  uriBuilder =
      uriBuilder.replaceQueryParam(OperationParam.NAME, uploadOperation).
          queryParam(DataParam.NAME, Boolean.TRUE);
  return uriBuilder.build(null);
}
项目：hadoop-TCP    文件：HttpFSServer.java    
/**
 * Special binding for '/' as it is not handled by the wildcard binding.
 *
 * @param user the principal of the user making the request.
 * @param op the HttpFS operation of the request.
 * @param params the HttpFS parameters of the request.
 *
 * @return the request response.
 *
 * @throws IOException thrown if an IO error occurred. Thrown exceptions are
 * handled by {@link HttpFSExceptionProvider}.
 * @throws FileSystemAccessException thrown if a FileSystemAccess releated
 * error occurred. Thrown exceptions are handled by
 * {@link HttpFSExceptionProvider}.
 */
@GET
@Produces(MediaType.APPLICATION_JSON)
public Response getRoot(@Context Principal user,
                        @QueryParam(OperationParam.NAME) OperationParam op,
                        @Context Parameters params)
  throws IOException, FileSystemAccessException {
  return get(user, "", op, params);
}
项目：hadoop-TCP    文件：HttpFSServer.java    
/**
 * Creates the URL for an upload operation (create or append).
 *
 * @param uriInfo uri info of the request.
 * @param uploadOperation operation for the upload URL.
 *
 * @return the URI for uploading data.
 */
protected URI createUploadRedirectionURL(UriInfo uriInfo, Enum<?> uploadOperation) {
  UriBuilder uriBuilder = uriInfo.getRequestUriBuilder();
  uriBuilder = uriBuilder.replaceQueryParam(OperationParam.NAME, uploadOperation).
    queryParam(DataParam.NAME, Boolean.TRUE);
  return uriBuilder.build(null);
}
项目：hardfs    文件：HttpFSServer.java    
/**
 * Special binding for '/' as it is not handled by the wildcard binding.
 *
 * @param user the principal of the user making the request.
 * @param op the HttpFS operation of the request.
 * @param params the HttpFS parameters of the request.
 *
 * @return the request response.
 *
 * @throws IOException thrown if an IO error occurred. Thrown exceptions are
 * handled by {@link HttpFSExceptionProvider}.
 * @throws FileSystemAccessException thrown if a FileSystemAccess releated
 * error occurred. Thrown exceptions are handled by
 * {@link HttpFSExceptionProvider}.
 */
@GET
@Produces(MediaType.APPLICATION_JSON)
public Response getRoot(@Context Principal user,
                        @QueryParam(OperationParam.NAME) OperationParam op,
                        @Context Parameters params)
  throws IOException, FileSystemAccessException {
  return get(user, "", op, params);
}
项目：hardfs    文件：HttpFSServer.java    
/**
 * Creates the URL for an upload operation (create or append).
 *
 * @param uriInfo uri info of the request.
 * @param uploadOperation operation for the upload URL.
 *
 * @return the URI for uploading data.
 */
protected URI createUploadRedirectionURL(UriInfo uriInfo, Enum<?> uploadOperation) {
  UriBuilder uriBuilder = uriInfo.getRequestUriBuilder();
  uriBuilder = uriBuilder.replaceQueryParam(OperationParam.NAME, uploadOperation).
    queryParam(DataParam.NAME, Boolean.TRUE);
  return uriBuilder.build(null);
}
项目：hadoop-on-lustre2    文件：HttpFSServer.java    
/**
 * Special binding for '/' as it is not handled by the wildcard binding.
 *
 * @param user the principal of the user making the request.
 * @param op the HttpFS operation of the request.
 * @param params the HttpFS parameters of the request.
 *
 * @return the request response.
 *
 * @throws IOException thrown if an IO error occurred. Thrown exceptions are
 * handled by {@link HttpFSExceptionProvider}.
 * @throws FileSystemAccessException thrown if a FileSystemAccess releated
 * error occurred. Thrown exceptions are handled by
 * {@link HttpFSExceptionProvider}.
 */
@GET
@Produces(MediaType.APPLICATION_JSON)
public Response getRoot(@Context Principal user,
                        @QueryParam(OperationParam.NAME) OperationParam op,
                        @Context Parameters params)
  throws IOException, FileSystemAccessException {
  return get(user, "", op, params);
}
项目：hadoop-on-lustre2    文件：HttpFSServer.java    
/**
 * Creates the URL for an upload operation (create or append).
 *
 * @param uriInfo uri info of the request.
 * @param uploadOperation operation for the upload URL.
 *
 * @return the URI for uploading data.
 */
protected URI createUploadRedirectionURL(UriInfo uriInfo, Enum<?> uploadOperation) {
  UriBuilder uriBuilder = uriInfo.getRequestUriBuilder();
  uriBuilder = uriBuilder.replaceQueryParam(OperationParam.NAME, uploadOperation).
    queryParam(DataParam.NAME, Boolean.TRUE);
  return uriBuilder.build(null);
}