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