From a18bc839d18bee634d0e35d4761bd156f0230f79 Mon Sep 17 00:00:00 2001 From: xuzifu666 <1206332514@qq.com> Date: Tue, 10 Aug 2021 23:18:12 +0800 Subject: [PATCH] [HUDI-2288] Support storage on ks3 for hudi (#3434) Co-authored-by: xuzifu --- .../src/main/java/org/apache/hudi/common/fs/StorageSchemes.java | 2 ++ .../test/java/org/apache/hudi/common/fs/TestStorageSchemes.java | 1 + 2 files changed, 3 insertions(+) diff --git a/hudi-common/src/main/java/org/apache/hudi/common/fs/StorageSchemes.java b/hudi-common/src/main/java/org/apache/hudi/common/fs/StorageSchemes.java index 40a8c9168..e166fc48e 100644 --- a/hudi-common/src/main/java/org/apache/hudi/common/fs/StorageSchemes.java +++ b/hudi-common/src/main/java/org/apache/hudi/common/fs/StorageSchemes.java @@ -60,6 +60,8 @@ public enum StorageSchemes { COS("cos", false), // Huawei Cloud Object Storage OBS("obs", false), + // Kingsoft Standard Storage ks3 + KS3("ks3", false), // Baidu Object Storage BOS("bos", false); diff --git a/hudi-common/src/test/java/org/apache/hudi/common/fs/TestStorageSchemes.java b/hudi-common/src/test/java/org/apache/hudi/common/fs/TestStorageSchemes.java index 8c4195f38..a346a673a 100644 --- a/hudi-common/src/test/java/org/apache/hudi/common/fs/TestStorageSchemes.java +++ b/hudi-common/src/test/java/org/apache/hudi/common/fs/TestStorageSchemes.java @@ -46,6 +46,7 @@ public class TestStorageSchemes { assertFalse(StorageSchemes.isAppendSupported("dbfs")); assertFalse(StorageSchemes.isAppendSupported("cos")); assertFalse(StorageSchemes.isAppendSupported("bos")); + assertFalse(StorageSchemes.isAppendSupported("ks3")); assertTrue(StorageSchemes.isAppendSupported("ofs")); assertThrows(IllegalArgumentException.class, () -> { StorageSchemes.isAppendSupported("s2");