branch-3.0: [opt](fs)add local file support #45632 (#45686)

Cherry-picked from #45632 Co-authored-by: wuwenchi <[email protected]>
apache · Dec 20, 2024 · 0137c8e · 0137c8e
1 parent 648e5dd
commit 0137c8e
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/property/PropertyConverter.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/property/PropertyConverter.java
@@ -41,6 +41,7 @@
 import com.google.common.collect.Maps;
 import org.apache.hadoop.fs.CosFileSystem;
 import org.apache.hadoop.fs.CosNConfigKeys;
+import org.apache.hadoop.fs.LocalFileSystem;
 import org.apache.hadoop.fs.aliyun.oss.AliyunOSSFileSystem;
 import org.apache.hadoop.fs.obs.OBSConstants;
 import org.apache.hadoop.fs.obs.OBSFileSystem;
@@ -193,6 +194,8 @@ private static Map<String, String> convertToOBSProperties(Map<String, String> pr
     public static String getHadoopFSImplByScheme(String fsScheme) {
         if (fsScheme.equalsIgnoreCase("obs")) {
             return OBSFileSystem.class.getName();
+        } else if (fsScheme.equalsIgnoreCase("file")) {
+            return LocalFileSystem.class.getName();
         } else if (fsScheme.equalsIgnoreCase("oss")) {
             return AliyunOSSFileSystem.class.getName();
         } else if (fsScheme.equalsIgnoreCase("cosn") || fsScheme.equalsIgnoreCase("lakefs")) {

diff --git a/fe/fe-core/src/main/java/org/apache/doris/fs/FileSystemFactory.java b/fe/fe-core/src/main/java/org/apache/doris/fs/FileSystemFactory.java
@@ -63,6 +63,7 @@ public static RemoteFileSystem getRemoteFileSystem(FileSystemType type, Map<Stri
                     return new AzureFileSystem(properties);
                 }
                 return new S3FileSystem(properties);
+            case FILE:
             case DFS:
                 return new DFSFileSystem(properties);
             case OFS: