From 673d62f3c3ab07abb3fcd319607e657339bc0682 Mon Sep 17 00:00:00 2001
From: Xuedong Luan <luanxuedong2009@gmail.com>
Date: Fri, 11 Jun 2021 09:16:51 +0800
Subject: [PATCH]  [MINOR] Add Tencent Cloud HDFS storage support for hudi
 (#3064)

---
 .../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 c6a20c994..40a8c9168 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 08a67d354..8c4195f38 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");