(paimon) branch master updated: [fileio] Delegate create()/getDefault() in HadoopSecuredFileSystem (#6602)

[lzljs3620320]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 46ae27949c [fileio] Delegate create()/getDefault() in 
HadoopSecuredFileSystem (#6602)
46ae27949c is described below

commit 46ae27949ce4cd8797bd71cc5bef1c9f3cc8e466
Author: SeungMin <semi...@gmail.com>
AuthorDate: Fri Nov 14 15:09:36 2025 +0900

    [fileio] Delegate create()/getDefault() in HadoopSecuredFileSystem (#6602)
---
 .../paimon/fs/hadoop/HadoopSecuredFileSystem.java  | 35 ++++++++++++++++++++++
 1 file changed, 35 insertions(+)

diff --git 
a/paimon-common/src/main/java/org/apache/paimon/fs/hadoop/HadoopSecuredFileSystem.java
 
b/paimon-common/src/main/java/org/apache/paimon/fs/hadoop/HadoopSecuredFileSystem.java
index 7d0b402383..d229579ce5 100644
--- 
a/paimon-common/src/main/java/org/apache/paimon/fs/hadoop/HadoopSecuredFileSystem.java
+++ 
b/paimon-common/src/main/java/org/apache/paimon/fs/hadoop/HadoopSecuredFileSystem.java
@@ -88,6 +88,41 @@ public class HadoopSecuredFileSystem extends FileSystem {
                                 progressable));
     }
 
+    @Override
+    public FSDataOutputStream create(Path path, boolean overwrite) throws 
IOException {
+        return runSecuredWithIOException(() -> fileSystem.create(path, 
overwrite));
+    }
+
+    @Override
+    public FSDataOutputStream create(
+            Path path, boolean overwrite, int bufferSize, short replication, 
long blockSize)
+            throws IOException {
+        return runSecuredWithIOException(
+                () -> fileSystem.create(path, overwrite, bufferSize, 
replication, blockSize));
+    }
+
+    @Override
+    public short getDefaultReplication(Path f) {
+        return runSecured(() -> fileSystem.getDefaultReplication(f));
+    }
+
+    @Deprecated
+    @Override
+    public short getDefaultReplication() {
+        return runSecured(() -> fileSystem.getDefaultReplication());
+    }
+
+    @Override
+    public long getDefaultBlockSize(Path f) {
+        return runSecured(() -> fileSystem.getDefaultBlockSize(f));
+    }
+
+    @Deprecated
+    @Override
+    public long getDefaultBlockSize() {
+        return runSecured(() -> fileSystem.getDefaultBlockSize());
+    }
+
     @Override
     public boolean exists(Path f) throws IOException {
         return runSecuredWithIOException(() -> fileSystem.exists(f));