Java 类org.apache.hadoop.hdfs.web.resources.CreateParentParam 实例源码

项目：hadoop-plus 文件：WebHdfsFileSystem.java

/**
 * Create a symlink pointing to the destination path.
 * @see org.apache.hadoop.fs.Hdfs#createSymlink(Path, Path, boolean) 
 */
public void createSymlink(Path destination, Path f, boolean createParent
    ) throws IOException {
  statistics.incrementWriteOps(1);
  final HttpOpParam.Op op = PutOpParam.Op.CREATESYMLINK;
  run(op, f, new DestinationParam(makeQualified(destination).toUri().getPath()),
      new CreateParentParam(createParent));
}

项目：hops 文件：WebHdfsFileSystem.java

/**
 * Create a symlink pointing to the destination path.
 *
 * @see org.apache.hadoop.fs.Hdfs#createSymlink(Path, Path, boolean)
 */
public void createSymlink(Path destination, Path f, boolean createParent)
    throws IOException {
  statistics.incrementWriteOps(1);
  final HttpOpParam.Op op = PutOpParam.Op.CREATESYMLINK;
  run(op, f,
      new DestinationParam(makeQualified(destination).toUri().getPath()),
      new CreateParentParam(createParent));
}

项目：hadoop-TCP 文件：WebHdfsFileSystem.java

/**
 * Create a symlink pointing to the destination path.
 * @see org.apache.hadoop.fs.Hdfs#createSymlink(Path, Path, boolean) 
 */
public void createSymlink(Path destination, Path f, boolean createParent
    ) throws IOException {
  statistics.incrementWriteOps(1);
  final HttpOpParam.Op op = PutOpParam.Op.CREATESYMLINK;
  run(op, f, new DestinationParam(makeQualified(destination).toUri().getPath()),
      new CreateParentParam(createParent));
}

项目：hardfs 文件：WebHdfsFileSystem.java

/**
 * Create a symlink pointing to the destination path.
 * @see org.apache.hadoop.fs.Hdfs#createSymlink(Path, Path, boolean) 
 */
public void createSymlink(Path destination, Path f, boolean createParent
    ) throws IOException {
  statistics.incrementWriteOps(1);
  final HttpOpParam.Op op = PutOpParam.Op.CREATESYMLINK;
  run(op, f, new DestinationParam(makeQualified(destination).toUri().getPath()),
      new CreateParentParam(createParent));
}

项目：hadoop-on-lustre2 文件：WebHdfsFileSystem.java

/**
 * Create a symlink pointing to the destination path.
 * @see org.apache.hadoop.fs.Hdfs#createSymlink(Path, Path, boolean) 
 */
public void createSymlink(Path destination, Path f, boolean createParent
    ) throws IOException {
  statistics.incrementWriteOps(1);
  final HttpOpParam.Op op = PutOpParam.Op.CREATESYMLINK;
  run(op, f, new DestinationParam(makeQualified(destination).toUri().getPath()),
      new CreateParentParam(createParent));
}

项目：aliyun-oss-hadoop-fs 文件：ParameterParser.java

public boolean createParent() {
  return new CreateParentParam(param(CreateParentParam.NAME)).getValue();
}

项目：hadoop-plus 文件：NamenodeWebHdfsMethods.java

/** 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);
}

项目：hadoop-plus 文件：NamenodeWebHdfsMethods.java

/** 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);
      }
    }
  });
}

项目：hops 文件：NamenodeWebHdfsMethods.java

/**
 * 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);
}

项目：hadoop-TCP 文件：NamenodeWebHdfsMethods.java

/** 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);
}

项目：hadoop-TCP 文件：NamenodeWebHdfsMethods.java

/** 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);
      }
    }
  });
}

项目：hardfs 文件：NamenodeWebHdfsMethods.java

/** 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);
}

项目：hardfs 文件：NamenodeWebHdfsMethods.java

/** 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);
      }
    }
  });
}

项目：hadoop-on-lustre2 文件：NamenodeWebHdfsMethods.java

/** 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);
}

项目：hadoop-on-lustre2 文件：NamenodeWebHdfsMethods.java

/** 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);
      }
    }
  });
}