(doris) branch master updated: [opt](fs)add local file support (#45632)

[morningman]

This is an automated email from the ASF dual-hosted git repository.

morningman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/master by this push:
     new d38970bf82d [opt](fs)add local file support (#45632)
d38970bf82d is described below

commit d38970bf82da2d9d3dd91ad21d96d66be6c5a147
Author: wuwenchi <wuwen...@selectdb.com>
AuthorDate: Fri Dec 20 09:43:16 2024 +0800

    [opt](fs)add local file support (#45632)
    
    ### What problem does this PR solve?
    
    Problem Summary:
    
    Added support for local files to facilitate debugging of some local
    files in the data lake.
---
 .../java/org/apache/doris/datasource/property/PropertyConverter.java   | 3 +++
 fe/fe-core/src/main/java/org/apache/doris/fs/FileSystemFactory.java    | 1 +
 2 files changed, 4 insertions(+)

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
index 8544ae597f1..7b65411aa6b 100644
--- 
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.base.Strings;
 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 @@ public class PropertyConverter {
     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
index 1f3d60d2adf..fb23005f4ac 100644
--- 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 class FileSystemFactory {
                     return new AzureFileSystem(properties);
                 }
                 return new S3FileSystem(properties);
+            case FILE:
             case DFS:
                 return new DFSFileSystem(properties);
             case OFS:


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org