From 1d53d6e6c2d3ff967d333d87b308406c8cd6917a Mon Sep 17 00:00:00 2001 From: Xu Guang Lv <17280256@qq.com> Date: Fri, 16 Apr 2021 16:43:14 +0800 Subject: [PATCH] [HUDI-1803] Support BAIDU AFS storage format in hudi (#2836) --- .../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 56c9c8e76..f5895f3a3 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 9f1262038..474d1208e 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"));