本文整理汇总了Java中org.apache.hadoop.fs.http.server.HttpFSParametersProvider.OperationParam类的典型用法代码示例。如果您正苦于以下问题：Java OperationParam类的具体用法？Java OperationParam怎么用？Java OperationParam使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
OperationParam类属于org.apache.hadoop.fs.http.server.HttpFSParametersProvider包，在下文中一共展示了OperationParam类的10个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: delete
import org.apache.hadoop.fs.http.server.HttpFSParametersProvider.OperationParam; //导入依赖的package包/类
/**
* 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;
}
开发者ID:naver，项目名称:hadoop，代码行数:48，代码来源:HttpFSServer.java
示例2: delete
import org.apache.hadoop.fs.http.server.HttpFSParametersProvider.OperationParam; //导入依赖的package包/类
/**
* 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;
}
开发者ID:Nextzero，项目名称:hadoop-2.6.0-cdh5.4.3，代码行数:46，代码来源:HttpFSServer.java
示例3: delete
import org.apache.hadoop.fs.http.server.HttpFSParametersProvider.OperationParam; //导入依赖的package包/类
/**
* 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;
}
开发者ID:ict-carch，项目名称:hadoop-plus，代码行数:48，代码来源:HttpFSServer.java
示例4: delete
import org.apache.hadoop.fs.http.server.HttpFSParametersProvider.OperationParam; //导入依赖的package包/类
/**
* 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;
}
开发者ID:hopshadoop，项目名称:hops，代码行数:55，代码来源:HttpFSServer.java
示例5: getRoot
import org.apache.hadoop.fs.http.server.HttpFSParametersProvider.OperationParam; //导入依赖的package包/类
/**
* 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);
}
开发者ID:naver，项目名称:hadoop，代码行数:23，代码来源:HttpFSServer.java
示例6: createUploadRedirectionURL
import org.apache.hadoop.fs.http.server.HttpFSParametersProvider.OperationParam; //导入依赖的package包/类
/**
* 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);
}
开发者ID:naver，项目名称:hadoop，代码行数:15，代码来源:HttpFSServer.java
示例7: getRoot
import org.apache.hadoop.fs.http.server.HttpFSParametersProvider.OperationParam; //导入依赖的package包/类
/**
* 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);
}
开发者ID:Nextzero，项目名称:hadoop-2.6.0-cdh5.4.3，代码行数:22，代码来源:HttpFSServer.java
示例8: getRoot
import org.apache.hadoop.fs.http.server.HttpFSParametersProvider.OperationParam; //导入依赖的package包/类
/**
* 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);
}
开发者ID:ict-carch，项目名称:hadoop-plus，代码行数:24，代码来源:HttpFSServer.java
示例9: getRoot
import org.apache.hadoop.fs.http.server.HttpFSParametersProvider.OperationParam; //导入依赖的package包/类
/**
* 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);
}
开发者ID:hopshadoop，项目名称:hops，代码行数:31，代码来源:HttpFSServer.java
示例10: createUploadRedirectionURL
import org.apache.hadoop.fs.http.server.HttpFSParametersProvider.OperationParam; //导入依赖的package包/类
/**
* 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);
}
开发者ID:hopshadoop，项目名称:hops，代码行数:18，代码来源:HttpFSServer.java
注：本文中的org.apache.hadoop.fs.http.server.HttpFSParametersProvider.OperationParam类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论