[hudi] branch master updated: [HUDI-5365] Add Volcengine Object Storage(tos) and Cloud HDFS(cfs) (#7425)

[danny0405]

This is an automated email from the ASF dual-hosted git repository.

danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new 6ef477238b4 [HUDI-5365] Add Volcengine Object Storage(tos) and Cloud 
HDFS(cfs) (#7425)
6ef477238b4 is described below

commit 6ef477238b4818b3a4da07f1426ea0dd296b7dbb
Author: stayrascal <stayras...@users.noreply.github.com>
AuthorDate: Thu Dec 15 13:23:14 2022 +0800

    [HUDI-5365] Add Volcengine Object Storage(tos) and Cloud HDFS(cfs) (#7425)
    
    Co-authored-by: wuzhiping <wuzhiping....@bytedance.com>
---
 .../src/main/java/org/apache/hudi/common/fs/StorageSchemes.java     | 6 +++++-
 .../src/test/java/org/apache/hudi/common/fs/TestStorageSchemes.java | 2 ++
 2 files changed, 7 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 10619f8b3af..9b5af8bc648 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
@@ -69,7 +69,11 @@ public enum StorageSchemes {
   // Baidu Object Storage
   BOS("bos", false),
   // Oracle Cloud Infrastructure Object Storage
-  OCI("oci", false);
+  OCI("oci", false),
+  // Volcengine Object Storage
+  TOS("tos", false),
+  // Volcengine Cloud HDFS
+  CFS("cfs", true);
 
   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 354ad6d0cca..7f2e0c2f8de 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
@@ -52,6 +52,8 @@ public class TestStorageSchemes {
     assertFalse(StorageSchemes.isAppendSupported("ks3"));
     assertTrue(StorageSchemes.isAppendSupported("ofs"));
     assertFalse(StorageSchemes.isAppendSupported("oci"));
+    assertFalse(StorageSchemes.isAppendSupported("tos"));
+    assertTrue(StorageSchemes.isAppendSupported("cfs"));
     assertThrows(IllegalArgumentException.class, () -> {
       StorageSchemes.isAppendSupported("s2");
     }, "Should throw exception for unsupported schemes");