You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@paimon.apache.org by lz...@apache.org on 2025/08/14 01:50:03 UTC

(paimon) branch master updated: [fs] Continue improving parameter naming in HadoopSecuredFileSystem (#6073)

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 59623c39ca [fs] Continue improving parameter naming in HadoopSecuredFileSystem (#6073)
59623c39ca is described below

commit 59623c39caa9ed83469b0e9d571078ccd2d24f80
Author: Jiajia Li <lj...@alibaba-inc.com>
AuthorDate: Thu Aug 14 09:49:58 2025 +0800

    [fs] Continue improving parameter naming in HadoopSecuredFileSystem (#6073)
---
 .../apache/paimon/fs/hadoop/HadoopSecuredFileSystem.java | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

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 6cc3ed0d1b..7d0b402383 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
@@ -62,8 +62,8 @@ public class HadoopSecuredFileSystem extends FileSystem {
     }
 
     @Override
-    public FSDataInputStream open(Path path, int i) throws IOException {
-        return runSecuredWithIOException(() -> fileSystem.open(path, i));
+    public FSDataInputStream open(Path path, int bufferSize) throws IOException {
+        return runSecuredWithIOException(() -> fileSystem.open(path, bufferSize));
     }
 
     @Override
@@ -94,19 +94,19 @@ public class HadoopSecuredFileSystem extends FileSystem {
     }
 
     @Override
-    public FSDataOutputStream append(Path path, int i, Progressable progressable)
+    public FSDataOutputStream append(Path path, int bufferSize, Progressable progressable)
             throws IOException {
-        return runSecuredWithIOException(() -> fileSystem.append(path, i, progressable));
+        return runSecuredWithIOException(() -> fileSystem.append(path, bufferSize, progressable));
     }
 
     @Override
-    public boolean rename(Path path, Path path1) throws IOException {
-        return runSecuredWithIOException(() -> fileSystem.rename(path, path1));
+    public boolean rename(Path src, Path dst) throws IOException {
+        return runSecuredWithIOException(() -> fileSystem.rename(src, dst));
     }
 
     @Override
-    public boolean delete(Path path, boolean b) throws IOException {
-        return runSecuredWithIOException(() -> fileSystem.delete(path, b));
+    public boolean delete(Path path, boolean recursive) throws IOException {
+        return runSecuredWithIOException(() -> fileSystem.delete(path, recursive));
     }
 
     @Override