Repository: hadoop Updated Branches: refs/heads/trunk 32a35dc94 -> d060cbea4
HDFS-13937. Multipart Uploader APIs to be marked as private/unstable in 3.2.0. Contributed by Steve Loughran. Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/d060cbea Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/d060cbea Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/d060cbea Branch: refs/heads/trunk Commit: d060cbea48ffc75da0f4fa98c3ea5203d6db1360 Parents: 32a35dc Author: Sunil G <[email protected]> Authored: Mon Sep 24 21:19:47 2018 +0530 Committer: Sunil G <[email protected]> Committed: Mon Sep 24 21:19:47 2018 +0530 ---------------------------------------------------------------------- .../src/main/java/org/apache/hadoop/fs/BBPartHandle.java | 5 +++++ .../src/main/java/org/apache/hadoop/fs/BBUploadHandle.java | 5 +++++ .../java/org/apache/hadoop/fs/FileSystemMultipartUploader.java | 4 ++++ .../src/main/java/org/apache/hadoop/fs/MultipartUploader.java | 5 +++++ .../java/org/apache/hadoop/fs/MultipartUploaderFactory.java | 4 ++++ .../java/org/apache/hadoop/fs/s3a/S3AMultipartUploader.java | 4 ++++ 6 files changed, 27 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/d060cbea/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/BBPartHandle.java ---------------------------------------------------------------------- diff --git a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/BBPartHandle.java b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/BBPartHandle.java index e1336b8..9df45a9 100644 --- a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/BBPartHandle.java +++ b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/BBPartHandle.java @@ -19,9 +19,14 @@ package org.apache.hadoop.fs; import java.nio.ByteBuffer; import java.util.Arrays; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; + /** * Byte array backed part handle. */ [email protected] [email protected] public final class BBPartHandle implements PartHandle { private static final long serialVersionUID = 0x23ce3eb1; http://git-wip-us.apache.org/repos/asf/hadoop/blob/d060cbea/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/BBUploadHandle.java ---------------------------------------------------------------------- diff --git a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/BBUploadHandle.java b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/BBUploadHandle.java index 6430c14..0d35bce 100644 --- a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/BBUploadHandle.java +++ b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/BBUploadHandle.java @@ -19,9 +19,14 @@ package org.apache.hadoop.fs; import java.nio.ByteBuffer; import java.util.Arrays; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; + /** * Byte array backed upload handle. */ [email protected] [email protected] public final class BBUploadHandle implements UploadHandle { private static final long serialVersionUID = 0x69d5509b; http://git-wip-us.apache.org/repos/asf/hadoop/blob/d060cbea/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileSystemMultipartUploader.java ---------------------------------------------------------------------- diff --git a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileSystemMultipartUploader.java b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileSystemMultipartUploader.java index f13b50b..690194d 100644 --- a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileSystemMultipartUploader.java +++ b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileSystemMultipartUploader.java @@ -28,6 +28,8 @@ import com.google.common.base.Preconditions; import org.apache.commons.compress.utils.IOUtils; import org.apache.commons.lang3.tuple.Pair; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.permission.FsPermission; @@ -44,6 +46,8 @@ import static org.apache.hadoop.fs.Path.mergePaths; * and then delete the temp directory.</li> * </ul> */ [email protected] [email protected] public class FileSystemMultipartUploader extends MultipartUploader { private final FileSystem fs; http://git-wip-us.apache.org/repos/asf/hadoop/blob/d060cbea/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/MultipartUploader.java ---------------------------------------------------------------------- diff --git a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/MultipartUploader.java b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/MultipartUploader.java index 76f58d3..b56dbf8 100644 --- a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/MultipartUploader.java +++ b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/MultipartUploader.java @@ -27,6 +27,9 @@ import org.slf4j.LoggerFactory; import org.apache.commons.lang3.tuple.Pair; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; + /** * MultipartUploader is an interface for copying files multipart and across * multiple nodes. Users should: @@ -41,6 +44,8 @@ import org.apache.commons.lang3.tuple.Pair; * that 'complete' will reorder parts if the destination FS doesn't already * do it for them. */ [email protected] [email protected] public abstract class MultipartUploader { public static final Logger LOG = LoggerFactory.getLogger(MultipartUploader.class); http://git-wip-us.apache.org/repos/asf/hadoop/blob/d060cbea/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/MultipartUploaderFactory.java ---------------------------------------------------------------------- diff --git a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/MultipartUploaderFactory.java b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/MultipartUploaderFactory.java index b0fa798..8b35232 100644 --- a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/MultipartUploaderFactory.java +++ b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/MultipartUploaderFactory.java @@ -16,6 +16,8 @@ */ package org.apache.hadoop.fs; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.conf.Configuration; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -28,6 +30,8 @@ import java.util.ServiceLoader; * {@link ServiceLoader}-driven uploader API for storage services supporting * multipart uploads. */ [email protected] [email protected] public abstract class MultipartUploaderFactory { public static final Logger LOG = LoggerFactory.getLogger(MultipartUploaderFactory.class); http://git-wip-us.apache.org/repos/asf/hadoop/blob/d060cbea/hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/S3AMultipartUploader.java ---------------------------------------------------------------------- diff --git a/hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/S3AMultipartUploader.java b/hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/S3AMultipartUploader.java index 4a6cb8c..cab4e2a 100644 --- a/hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/S3AMultipartUploader.java +++ b/hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/S3AMultipartUploader.java @@ -38,6 +38,8 @@ import com.google.common.base.Preconditions; import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.tuple.Pair; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.BBPartHandle; import org.apache.hadoop.fs.BBUploadHandle; @@ -55,6 +57,8 @@ import static org.apache.hadoop.fs.s3a.Constants.FS_S3A; * MultipartUploader for S3AFileSystem. This uses the S3 multipart * upload mechanism. */ [email protected] [email protected] public class S3AMultipartUploader extends MultipartUploader { private final S3AFileSystem s3a; --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
