[MINOR] Add Hopsworks File System to StorageSchemes (apache#10141)

jonvex · Nov 20, 2023 · 3225625 · 3225625
1 parent 3913dca
commit 3225625
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 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
@@ -77,7 +77,9 @@ public enum StorageSchemes {
   // Volcengine Object Storage
   TOS("tos", null, null),
   // Volcengine Cloud HDFS
-  CFS("cfs", null, null);
+  CFS("cfs", null, null),
+  // Hopsworks File System
+  HOPSFS("hopsfs", false, true);
 
   private String scheme;
   // null for uncertain if write is transactional, please update this for each FS

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
@@ -57,6 +57,7 @@ public void testStorageSchemes() {
     assertFalse(StorageSchemes.isAtomicCreationSupported("oci"));
     assertFalse(StorageSchemes.isAtomicCreationSupported("tos"));
     assertFalse(StorageSchemes.isAtomicCreationSupported("cfs"));
+    assertTrue(StorageSchemes.isAtomicCreationSupported("hopsfs"));
   }
 
   @Test