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");