From 32ea4c70ff259798dee571670dbcc501cc477cb0 Mon Sep 17 00:00:00 2001 From: liujinhui <965147871@qq.com> Date: Wed, 13 May 2020 21:00:34 +0800 Subject: [PATCH] [HUDI-869] Add support for alluxio (#1608) --- .../main/java/org/apache/hudi/common/fs/StorageSchemes.java | 4 +++- .../org/apache/hudi/common/storage/TestStorageSchemes.java | 1 + 2 files changed, 4 insertions(+), 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 index 06e194329..1b6aea7b8 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 @@ -45,7 +45,9 @@ public enum StorageSchemes { // Aliyun OSS OSS("oss", false), // View FS for federated setups. If federating across cloud stores, then append support is false - VIEWFS("viewfs", true); + VIEWFS("viewfs", true), + //ALLUXIO + ALLUXIO("alluxio", false); private String scheme; private boolean supportsAppend; diff --git a/hudi-common/src/test/java/org/apache/hudi/common/storage/TestStorageSchemes.java b/hudi-common/src/test/java/org/apache/hudi/common/storage/TestStorageSchemes.java index 22507c857..f3b6c9f91 100644 --- a/hudi-common/src/test/java/org/apache/hudi/common/storage/TestStorageSchemes.java +++ b/hudi-common/src/test/java/org/apache/hudi/common/storage/TestStorageSchemes.java @@ -42,6 +42,7 @@ public class TestStorageSchemes { assertFalse(StorageSchemes.isAppendSupported("abfs")); assertFalse(StorageSchemes.isAppendSupported("oss")); assertTrue(StorageSchemes.isAppendSupported("viewfs")); + assertFalse(StorageSchemes.isAppendSupported("alluxio")); assertThrows(IllegalArgumentException.class, () -> { StorageSchemes.isAppendSupported("s2"); }, "Should throw exception for unsupported schemes");