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 56c9c8e766ce..f5895f3a3023 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 @@ -28,6 +28,8 @@ public enum StorageSchemes { FILE("file", false), // Hadoop File System HDFS("hdfs", true), + // Baidu Advanced File System + AFS("afs", true), // Mapr File System MAPRFS("maprfs", true), // Apache Ignite 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 index 9f12620384c3..474d1208e844 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 @@ -32,6 +32,7 @@ public class TestStorageSchemes { @Test public void testStorageSchemes() { assertTrue(StorageSchemes.isSchemeSupported("hdfs")); + assertTrue(StorageSchemes.isSchemeSupported("afs")); assertFalse(StorageSchemes.isSchemeSupported("s2")); assertFalse(StorageSchemes.isAppendSupported("s3a")); assertFalse(StorageSchemes.isAppendSupported("gs"));