From 743ef322b88d90be9775b889f6381925cdda5f35 Mon Sep 17 00:00:00 2001 From: DeyinZhong <44561252+DeyinZhong@users.noreply.github.com> Date: Wed, 22 Jul 2020 17:40:19 +0800 Subject: [PATCH] [HUDI-871] Add support for Tencent Cloud Object Storage(COS) (#1855) Co-authored-by: deyzhong --- .../main/java/org/apache/hudi/common/fs/StorageSchemes.java | 4 +++- .../java/org/apache/hudi/common/fs/TestStorageSchemes.java | 1 + 2 files changed, 4 insertions(+), 1 deletion(-) 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 1b6aea7b8..06b92fd9d 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 @@ -47,7 +47,9 @@ public enum StorageSchemes { // View FS for federated setups. If federating across cloud stores, then append support is false VIEWFS("viewfs", true), //ALLUXIO - ALLUXIO("alluxio", false); + ALLUXIO("alluxio", false), + // Tencent Cloud Object Storage + COSN("cosn", false); private String scheme; private boolean supportsAppend; 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 4cf826077..48e4b7510 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 @@ -41,6 +41,7 @@ public class TestStorageSchemes { assertFalse(StorageSchemes.isAppendSupported("oss")); assertTrue(StorageSchemes.isAppendSupported("viewfs")); assertFalse(StorageSchemes.isAppendSupported("alluxio")); + assertFalse(StorageSchemes.isAppendSupported("cosn")); assertThrows(IllegalArgumentException.class, () -> { StorageSchemes.isAppendSupported("s2"); }, "Should throw exception for unsupported schemes");