[hudi] branch master updated: [MINOR] Add Tencent Cloud HDFS storage support for hudi (#3064)

[leesf]

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

leesf 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 673d62f   [MINOR] Add Tencent Cloud HDFS storage support for hudi 
(#3064)
673d62f is described below

commit 673d62f3c3ab07abb3fcd319607e657339bc0682
Author: Xuedong Luan <luanxuedong2...@gmail.com>
AuthorDate: Fri Jun 11 09:16:51 2021 +0800

     [MINOR] Add Tencent Cloud HDFS storage support for hudi (#3064)
---
 hudi-common/src/main/java/org/apache/hudi/common/fs/StorageSchemes.java | 2 ++
 .../src/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 c6a20c9..40a8c91 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
@@ -52,6 +52,8 @@ public enum StorageSchemes {
   ALLUXIO("alluxio", false),
   // Tencent Cloud Object Storage
   COSN("cosn", false),
+  // Tencent Cloud HDFS
+  CHDFS("ofs", true),
   // Databricks file system
   DBFS("dbfs", false),
   // IBM Cloud Object Storage
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 08a67d3..8c4195f 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"));
+    assertTrue(StorageSchemes.isAppendSupported("ofs"));
     assertThrows(IllegalArgumentException.class, () -> {
       StorageSchemes.isAppendSupported("s2");
     }, "Should throw exception for unsupported schemes");