• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号
登陆 注册

Java OwnerParam类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.apache.hadoop.hdfs.web.resources.OwnerParam类的典型用法代码示例。如果您正苦于以下问题：Java OwnerParam类的具体用法？Java OwnerParam怎么用？Java OwnerParam使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



OwnerParam类属于org.apache.hadoop.hdfs.web.resources包，在下文中一共展示了OwnerParam类的8个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: setOwner

import org.apache.hadoop.hdfs.web.resources.OwnerParam; //导入依赖的package包/类
@Override
public void setOwner(final Path p, final String owner, final String group
    ) throws IOException {
  if (owner == null && group == null) {
    throw new IOException("owner == null && group == null");
  }

  statistics.incrementWriteOps(1);
  final HttpOpParam.Op op = PutOpParam.Op.SETOWNER;
  run(op, p, new OwnerParam(owner), new GroupParam(group));
}
开发者ID:ict-carch，项目名称:hadoop-plus，代码行数:12，代码来源:WebHdfsFileSystem.java


示例2: setOwner

import org.apache.hadoop.hdfs.web.resources.OwnerParam; //导入依赖的package包/类
@Override
public void setOwner(final Path p, final String owner, final String group)
    throws IOException {
  if (owner == null && group == null) {
    throw new IOException("owner == null && group == null");
  }

  statistics.incrementWriteOps(1);
  final HttpOpParam.Op op = PutOpParam.Op.SETOWNER;
  run(op, p, new OwnerParam(owner), new GroupParam(group));
}
开发者ID:hopshadoop，项目名称:hops，代码行数:12，代码来源:WebHdfsFileSystem.java


示例3: putRoot

import org.apache.hadoop.hdfs.web.resources.OwnerParam; //导入依赖的package包/类
/** Handle HTTP PUT request for the root. */
@PUT
@Path("/")
@Consumes({"*/*"})
@Produces({MediaType.APPLICATION_OCTET_STREAM, MediaType.APPLICATION_JSON})
public Response putRoot(
    @Context final UserGroupInformation ugi,
    @QueryParam(DelegationParam.NAME) @DefaultValue(DelegationParam.DEFAULT)
        final DelegationParam delegation,
    @QueryParam(UserParam.NAME) @DefaultValue(UserParam.DEFAULT)
        final UserParam username,
    @QueryParam(DoAsParam.NAME) @DefaultValue(DoAsParam.DEFAULT)
        final DoAsParam doAsUser,
    @QueryParam(PutOpParam.NAME) @DefaultValue(PutOpParam.DEFAULT)
        final PutOpParam op,
    @QueryParam(DestinationParam.NAME) @DefaultValue(DestinationParam.DEFAULT)
        final DestinationParam destination,
    @QueryParam(OwnerParam.NAME) @DefaultValue(OwnerParam.DEFAULT)
        final OwnerParam owner,
    @QueryParam(GroupParam.NAME) @DefaultValue(GroupParam.DEFAULT)
        final GroupParam group,
    @QueryParam(PermissionParam.NAME) @DefaultValue(PermissionParam.DEFAULT)
        final PermissionParam permission,
    @QueryParam(OverwriteParam.NAME) @DefaultValue(OverwriteParam.DEFAULT)
        final OverwriteParam overwrite,
    @QueryParam(BufferSizeParam.NAME) @DefaultValue(BufferSizeParam.DEFAULT)
        final BufferSizeParam bufferSize,
    @QueryParam(ReplicationParam.NAME) @DefaultValue(ReplicationParam.DEFAULT)
        final ReplicationParam replication,
    @QueryParam(BlockSizeParam.NAME) @DefaultValue(BlockSizeParam.DEFAULT)
        final BlockSizeParam blockSize,
    @QueryParam(ModificationTimeParam.NAME) @DefaultValue(ModificationTimeParam.DEFAULT)
        final ModificationTimeParam modificationTime,
    @QueryParam(AccessTimeParam.NAME) @DefaultValue(AccessTimeParam.DEFAULT)
        final AccessTimeParam accessTime,
    @QueryParam(RenameOptionSetParam.NAME) @DefaultValue(RenameOptionSetParam.DEFAULT)
        final RenameOptionSetParam renameOptions,
    @QueryParam(CreateParentParam.NAME) @DefaultValue(CreateParentParam.DEFAULT)
        final CreateParentParam createParent,
    @QueryParam(TokenArgumentParam.NAME) @DefaultValue(TokenArgumentParam.DEFAULT)
        final TokenArgumentParam delegationTokenArgument
    ) throws IOException, InterruptedException {
  return put(ugi, delegation, username, doAsUser, ROOT, op, destination,
      owner, group, permission, overwrite, bufferSize, replication,
      blockSize, modificationTime, accessTime, renameOptions, createParent,
      delegationTokenArgument);
}
开发者ID:ict-carch，项目名称:hadoop-plus，代码行数:48，代码来源:NamenodeWebHdfsMethods.java


示例4: put

import org.apache.hadoop.hdfs.web.resources.OwnerParam; //导入依赖的package包/类
/** Handle HTTP PUT request. */
@PUT
@Path("{" + UriFsPathParam.NAME + ":.*}")
@Consumes({"*/*"})
@Produces({MediaType.APPLICATION_OCTET_STREAM, MediaType.APPLICATION_JSON})
public Response put(
    @Context final UserGroupInformation ugi,
    @QueryParam(DelegationParam.NAME) @DefaultValue(DelegationParam.DEFAULT)
        final DelegationParam delegation,
    @QueryParam(UserParam.NAME) @DefaultValue(UserParam.DEFAULT)
        final UserParam username,
    @QueryParam(DoAsParam.NAME) @DefaultValue(DoAsParam.DEFAULT)
        final DoAsParam doAsUser,
    @PathParam(UriFsPathParam.NAME) final UriFsPathParam path,
    @QueryParam(PutOpParam.NAME) @DefaultValue(PutOpParam.DEFAULT)
        final PutOpParam op,
    @QueryParam(DestinationParam.NAME) @DefaultValue(DestinationParam.DEFAULT)
        final DestinationParam destination,
    @QueryParam(OwnerParam.NAME) @DefaultValue(OwnerParam.DEFAULT)
        final OwnerParam owner,
    @QueryParam(GroupParam.NAME) @DefaultValue(GroupParam.DEFAULT)
        final GroupParam group,
    @QueryParam(PermissionParam.NAME) @DefaultValue(PermissionParam.DEFAULT)
        final PermissionParam permission,
    @QueryParam(OverwriteParam.NAME) @DefaultValue(OverwriteParam.DEFAULT)
        final OverwriteParam overwrite,
    @QueryParam(BufferSizeParam.NAME) @DefaultValue(BufferSizeParam.DEFAULT)
        final BufferSizeParam bufferSize,
    @QueryParam(ReplicationParam.NAME) @DefaultValue(ReplicationParam.DEFAULT)
        final ReplicationParam replication,
    @QueryParam(BlockSizeParam.NAME) @DefaultValue(BlockSizeParam.DEFAULT)
        final BlockSizeParam blockSize,
    @QueryParam(ModificationTimeParam.NAME) @DefaultValue(ModificationTimeParam.DEFAULT)
        final ModificationTimeParam modificationTime,
    @QueryParam(AccessTimeParam.NAME) @DefaultValue(AccessTimeParam.DEFAULT)
        final AccessTimeParam accessTime,
    @QueryParam(RenameOptionSetParam.NAME) @DefaultValue(RenameOptionSetParam.DEFAULT)
        final RenameOptionSetParam renameOptions,
    @QueryParam(CreateParentParam.NAME) @DefaultValue(CreateParentParam.DEFAULT)
        final CreateParentParam createParent,
    @QueryParam(TokenArgumentParam.NAME) @DefaultValue(TokenArgumentParam.DEFAULT)
        final TokenArgumentParam delegationTokenArgument
    ) throws IOException, InterruptedException {

  init(ugi, delegation, username, doAsUser, path, op, destination, owner,
      group, permission, overwrite, bufferSize, replication, blockSize,
      modificationTime, accessTime, renameOptions, delegationTokenArgument);

  return ugi.doAs(new PrivilegedExceptionAction<Response>() {
    @Override
    public Response run() throws IOException, URISyntaxException {
      REMOTE_ADDRESS.set(request.getRemoteAddr());
      try {
        return put(ugi, delegation, username, doAsUser,
            path.getAbsolutePath(), op, destination, owner, group,
            permission, overwrite, bufferSize, replication, blockSize,
            modificationTime, accessTime, renameOptions, createParent,
            delegationTokenArgument);
      } finally {
        REMOTE_ADDRESS.set(null);
      }
    }
  });
}
开发者ID:ict-carch，项目名称:hadoop-plus，代码行数:65，代码来源:NamenodeWebHdfsMethods.java


示例5: putRoot

import org.apache.hadoop.hdfs.web.resources.OwnerParam; //导入依赖的package包/类
/**
 * Handle HTTP PUT request for the root.
 */
@PUT
@Path("/")
@Consumes({"*/*"})
@Produces({MediaType.APPLICATION_OCTET_STREAM, MediaType.APPLICATION_JSON})
public Response putRoot(
    @Context
    final UserGroupInformation ugi,
    @QueryParam(DelegationParam.NAME)
    @DefaultValue(DelegationParam.DEFAULT)
    final DelegationParam delegation,
    @QueryParam(UserParam.NAME)
    @DefaultValue(UserParam.DEFAULT)
    final UserParam username,
    @QueryParam(DoAsParam.NAME)
    @DefaultValue(DoAsParam.DEFAULT)
    final DoAsParam doAsUser,
    @QueryParam(PutOpParam.NAME)
    @DefaultValue(PutOpParam.DEFAULT)
    final PutOpParam op,
    @QueryParam(DestinationParam.NAME)
    @DefaultValue(DestinationParam.DEFAULT)
    final DestinationParam destination,
    @QueryParam(OwnerParam.NAME)
    @DefaultValue(OwnerParam.DEFAULT)
    final OwnerParam owner,
    @QueryParam(GroupParam.NAME)
    @DefaultValue(GroupParam.DEFAULT)
    final GroupParam group,
    @QueryParam(PermissionParam.NAME)
    @DefaultValue(PermissionParam.DEFAULT)
    final PermissionParam permission,
    @QueryParam(OverwriteParam.NAME)
    @DefaultValue(OverwriteParam.DEFAULT)
    final OverwriteParam overwrite,
    @QueryParam(BufferSizeParam.NAME)
    @DefaultValue(BufferSizeParam.DEFAULT)
    final BufferSizeParam bufferSize,
    @QueryParam(ReplicationParam.NAME)
    @DefaultValue(ReplicationParam.DEFAULT)
    final ReplicationParam replication,
    @QueryParam(BlockSizeParam.NAME)
    @DefaultValue(BlockSizeParam.DEFAULT)
    final BlockSizeParam blockSize,
    @QueryParam(ModificationTimeParam.NAME)
    @DefaultValue(ModificationTimeParam.DEFAULT)
    final ModificationTimeParam modificationTime,
    @QueryParam(AccessTimeParam.NAME)
    @DefaultValue(AccessTimeParam.DEFAULT)
    final AccessTimeParam accessTime,
    @QueryParam(RenameOptionSetParam.NAME)
    @DefaultValue(RenameOptionSetParam.DEFAULT)
    final RenameOptionSetParam renameOptions,
    @QueryParam(CreateParentParam.NAME)
    @DefaultValue(CreateParentParam.DEFAULT)
    final CreateParentParam createParent,
    @QueryParam(TokenArgumentParam.NAME)
    @DefaultValue(TokenArgumentParam.DEFAULT)
    final TokenArgumentParam delegationTokenArgument)
    throws IOException, InterruptedException {
  return put(ugi, delegation, username, doAsUser, ROOT, op, destination,
      owner, group, permission, overwrite, bufferSize, replication, blockSize,
      modificationTime, accessTime, renameOptions, createParent,
      delegationTokenArgument);
}
开发者ID:hopshadoop，项目名称:hops，代码行数:68，代码来源:NamenodeWebHdfsMethods.java


示例6: putRoot

import org.apache.hadoop.hdfs.web.resources.OwnerParam; //导入依赖的package包/类
/** Handle HTTP PUT request for the root. */
@PUT
@Path("/")
@Consumes({"*/*"})
@Produces({MediaType.APPLICATION_OCTET_STREAM, MediaType.APPLICATION_JSON})
public Response putRoot(
    @Context final UserGroupInformation ugi,
    @QueryParam(DelegationParam.NAME) @DefaultValue(DelegationParam.DEFAULT)
        final DelegationParam delegation,
    @QueryParam(UserParam.NAME) @DefaultValue(UserParam.DEFAULT)
        final UserParam username,
    @QueryParam(DoAsParam.NAME) @DefaultValue(DoAsParam.DEFAULT)
        final DoAsParam doAsUser,
    @QueryParam(PutOpParam.NAME) @DefaultValue(PutOpParam.DEFAULT)
        final PutOpParam op,
    @QueryParam(DestinationParam.NAME) @DefaultValue(DestinationParam.DEFAULT)
        final DestinationParam destination,
    @QueryParam(OwnerParam.NAME) @DefaultValue(OwnerParam.DEFAULT)
        final OwnerParam owner,
    @QueryParam(GroupParam.NAME) @DefaultValue(GroupParam.DEFAULT)
        final GroupParam group,
    @QueryParam(PermissionParam.NAME) @DefaultValue(PermissionParam.DEFAULT)
        final PermissionParam permission,
    @QueryParam(OverwriteParam.NAME) @DefaultValue(OverwriteParam.DEFAULT)
        final OverwriteParam overwrite,
    @QueryParam(BufferSizeParam.NAME) @DefaultValue(BufferSizeParam.DEFAULT)
        final BufferSizeParam bufferSize,
    @QueryParam(ReplicationParam.NAME) @DefaultValue(ReplicationParam.DEFAULT)
        final ReplicationParam replication,
    @QueryParam(BlockSizeParam.NAME) @DefaultValue(BlockSizeParam.DEFAULT)
        final BlockSizeParam blockSize,
    @QueryParam(ModificationTimeParam.NAME) @DefaultValue(ModificationTimeParam.DEFAULT)
        final ModificationTimeParam modificationTime,
    @QueryParam(AccessTimeParam.NAME) @DefaultValue(AccessTimeParam.DEFAULT)
        final AccessTimeParam accessTime,
    @QueryParam(TokenArgumentParam.NAME) @DefaultValue(TokenArgumentParam.DEFAULT)
        final TokenArgumentParam delegationTokenArgument
    ) throws IOException, InterruptedException {
  return put(ugi, delegation, username, doAsUser, ROOT, op, destination,
      owner, group, permission, overwrite, bufferSize, replication,
      blockSize, modificationTime, accessTime, delegationTokenArgument);
}
开发者ID:Seagate，项目名称:hadoop-on-lustre，代码行数:43，代码来源:NamenodeWebHdfsMethods.java


示例7: putRoot

import org.apache.hadoop.hdfs.web.resources.OwnerParam; //导入依赖的package包/类
/** Handle HTTP PUT request for the root. */
@PUT
@Path("/")
@Consumes({"*/*"})
@Produces({MediaType.APPLICATION_OCTET_STREAM, MediaType.APPLICATION_JSON})
public Response putRoot(
    @Context final UserGroupInformation ugi,
    @QueryParam(DelegationParam.NAME) @DefaultValue(DelegationParam.DEFAULT)
        final DelegationParam delegation,
    @QueryParam(UserParam.NAME) @DefaultValue(UserParam.DEFAULT)
        final UserParam username,
    @QueryParam(DoAsParam.NAME) @DefaultValue(DoAsParam.DEFAULT)
        final DoAsParam doAsUser,
    @QueryParam(PutOpParam.NAME) @DefaultValue(PutOpParam.DEFAULT)
        final PutOpParam op,
    @QueryParam(DestinationParam.NAME) @DefaultValue(DestinationParam.DEFAULT)
        final DestinationParam destination,
    @QueryParam(OwnerParam.NAME) @DefaultValue(OwnerParam.DEFAULT)
        final OwnerParam owner,
    @QueryParam(GroupParam.NAME) @DefaultValue(GroupParam.DEFAULT)
        final GroupParam group,
    @QueryParam(PermissionParam.NAME) @DefaultValue(PermissionParam.DEFAULT)
        final PermissionParam permission,
    @QueryParam(OverwriteParam.NAME) @DefaultValue(OverwriteParam.DEFAULT)
        final OverwriteParam overwrite,
    @QueryParam(BufferSizeParam.NAME) @DefaultValue(BufferSizeParam.DEFAULT)
        final BufferSizeParam bufferSize,
    @QueryParam(ReplicationParam.NAME) @DefaultValue(ReplicationParam.DEFAULT)
        final ReplicationParam replication,
    @QueryParam(BlockSizeParam.NAME) @DefaultValue(BlockSizeParam.DEFAULT)
        final BlockSizeParam blockSize,
    @QueryParam(ModificationTimeParam.NAME) @DefaultValue(ModificationTimeParam.DEFAULT)
        final ModificationTimeParam modificationTime,
    @QueryParam(AccessTimeParam.NAME) @DefaultValue(AccessTimeParam.DEFAULT)
        final AccessTimeParam accessTime,
    @QueryParam(RenameOptionSetParam.NAME) @DefaultValue(RenameOptionSetParam.DEFAULT)
        final RenameOptionSetParam renameOptions,
    @QueryParam(CreateParentParam.NAME) @DefaultValue(CreateParentParam.DEFAULT)
        final CreateParentParam createParent,
    @QueryParam(TokenArgumentParam.NAME) @DefaultValue(TokenArgumentParam.DEFAULT)
        final TokenArgumentParam delegationTokenArgument,
    @QueryParam(AclPermissionParam.NAME) @DefaultValue(AclPermissionParam.DEFAULT) 
        final AclPermissionParam aclPermission
        )throws IOException, InterruptedException {
  return put(ugi, delegation, username, doAsUser, ROOT, op, destination,
      owner, group, permission, overwrite, bufferSize, replication,
      blockSize, modificationTime, accessTime, renameOptions, createParent,
      delegationTokenArgument,aclPermission);
}
开发者ID:Seagate，项目名称:hadoop-on-lustre2，代码行数:50，代码来源:NamenodeWebHdfsMethods.java


示例8: put

import org.apache.hadoop.hdfs.web.resources.OwnerParam; //导入依赖的package包/类
/** Handle HTTP PUT request. */
@PUT
@Path("{" + UriFsPathParam.NAME + ":.*}")
@Consumes({"*/*"})
@Produces({MediaType.APPLICATION_OCTET_STREAM, MediaType.APPLICATION_JSON})
public Response put(
    @Context final UserGroupInformation ugi,
    @QueryParam(DelegationParam.NAME) @DefaultValue(DelegationParam.DEFAULT)
        final DelegationParam delegation,
    @QueryParam(UserParam.NAME) @DefaultValue(UserParam.DEFAULT)
        final UserParam username,
    @QueryParam(DoAsParam.NAME) @DefaultValue(DoAsParam.DEFAULT)
        final DoAsParam doAsUser,
    @PathParam(UriFsPathParam.NAME) final UriFsPathParam path,
    @QueryParam(PutOpParam.NAME) @DefaultValue(PutOpParam.DEFAULT)
        final PutOpParam op,
    @QueryParam(DestinationParam.NAME) @DefaultValue(DestinationParam.DEFAULT)
        final DestinationParam destination,
    @QueryParam(OwnerParam.NAME) @DefaultValue(OwnerParam.DEFAULT)
        final OwnerParam owner,
    @QueryParam(GroupParam.NAME) @DefaultValue(GroupParam.DEFAULT)
        final GroupParam group,
    @QueryParam(PermissionParam.NAME) @DefaultValue(PermissionParam.DEFAULT)
        final PermissionParam permission,
    @QueryParam(OverwriteParam.NAME) @DefaultValue(OverwriteParam.DEFAULT)
        final OverwriteParam overwrite,
    @QueryParam(BufferSizeParam.NAME) @DefaultValue(BufferSizeParam.DEFAULT)
        final BufferSizeParam bufferSize,
    @QueryParam(ReplicationParam.NAME) @DefaultValue(ReplicationParam.DEFAULT)
        final ReplicationParam replication,
    @QueryParam(BlockSizeParam.NAME) @DefaultValue(BlockSizeParam.DEFAULT)
        final BlockSizeParam blockSize,
    @QueryParam(ModificationTimeParam.NAME) @DefaultValue(ModificationTimeParam.DEFAULT)
        final ModificationTimeParam modificationTime,
    @QueryParam(AccessTimeParam.NAME) @DefaultValue(AccessTimeParam.DEFAULT)
        final AccessTimeParam accessTime,
    @QueryParam(RenameOptionSetParam.NAME) @DefaultValue(RenameOptionSetParam.DEFAULT)
        final RenameOptionSetParam renameOptions,
    @QueryParam(CreateParentParam.NAME) @DefaultValue(CreateParentParam.DEFAULT)
        final CreateParentParam createParent,
    @QueryParam(TokenArgumentParam.NAME) @DefaultValue(TokenArgumentParam.DEFAULT)
        final TokenArgumentParam delegationTokenArgument,
    @QueryParam(AclPermissionParam.NAME) @DefaultValue(AclPermissionParam.DEFAULT) 
        final AclPermissionParam aclPermission
    ) throws IOException, InterruptedException {

  init(ugi, delegation, username, doAsUser, path, op, destination, owner,
      group, permission, overwrite, bufferSize, replication, blockSize,
      modificationTime, accessTime, renameOptions, delegationTokenArgument,aclPermission);

  return ugi.doAs(new PrivilegedExceptionAction<Response>() {
    @Override
    public Response run() throws IOException, URISyntaxException {
      REMOTE_ADDRESS.set(request.getRemoteAddr());
      try {
        return put(ugi, delegation, username, doAsUser,
            path.getAbsolutePath(), op, destination, owner, group,
            permission, overwrite, bufferSize, replication, blockSize,
            modificationTime, accessTime, renameOptions, createParent,
            delegationTokenArgument,aclPermission);
      } finally {
        REMOTE_ADDRESS.set(null);
      }
    }
  });
}
开发者ID:Seagate，项目名称:hadoop-on-lustre2，代码行数:67，代码来源:NamenodeWebHdfsMethods.java



注：本文中的org.apache.hadoop.hdfs.web.resources.OwnerParam类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花
握手
雷人
路过
鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
More+
上一篇：
Java NotOfficeXmlFileException类代码示例发布时间：2022-05-23
下一篇：
Java GroupManager类代码示例发布时间：2022-05-23
热门推荐
More+
热门话题
More+
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服（服务时间 9:00～18:00）

在线QQ客服
地址：深圳市南山区西丽大学城创智工业园
电邮：jeky_zhao#qq.com
移动电话：139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap