This is an automated email from the ASF dual-hosted git repository.
JingsongLi 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 b782f24a23 [core] Remove useless arguement in ObjectsFile
b782f24a23 is described below
commit b782f24a23e2dc7a968f476db7155ee6b454cc72
Author: JingsongLi <[email protected]>
AuthorDate: Wed Jun 24 19:26:47 2026 +0800
[core] Remove useless arguement in ObjectsFile
---
.../java/org/apache/paimon/manifest/FileEntry.java | 1 -
.../java/org/apache/paimon/utils/ObjectsFile.java | 27 ++++------------------
2 files changed, 4 insertions(+), 24 deletions(-)
diff --git
a/paimon-core/src/main/java/org/apache/paimon/manifest/FileEntry.java
b/paimon-core/src/main/java/org/apache/paimon/manifest/FileEntry.java
index 3daf423529..62f3f685c9 100644
--- a/paimon-core/src/main/java/org/apache/paimon/manifest/FileEntry.java
+++ b/paimon-core/src/main/java/org/apache/paimon/manifest/FileEntry.java
@@ -242,7 +242,6 @@ public interface FileEntry {
manifestFile.read(
m.fileName(),
m.fileSize(),
- Filter.alwaysTrue(),
deletedFilter(),
Filter.alwaysTrue(),
SimpleFileEntry::from),
diff --git a/paimon-core/src/main/java/org/apache/paimon/utils/ObjectsFile.java
b/paimon-core/src/main/java/org/apache/paimon/utils/ObjectsFile.java
index 2ec44afdd5..deb6c91214 100644
--- a/paimon-core/src/main/java/org/apache/paimon/utils/ObjectsFile.java
+++ b/paimon-core/src/main/java/org/apache/paimon/utils/ObjectsFile.java
@@ -102,12 +102,7 @@ public abstract class ObjectsFile<T> implements
SimpleFileReader<T> {
public List<T> read(String fileName, @Nullable Long fileSize) {
return read(
- fileName,
- fileSize,
- Filter.alwaysTrue(),
- Filter.alwaysTrue(),
- Filter.alwaysTrue(),
- Function.identity());
+ fileName, fileSize, Filter.alwaysTrue(), Filter.alwaysTrue(),
Function.identity());
}
public List<T> readWithIOException(String fileName) throws IOException {
@@ -117,12 +112,7 @@ public abstract class ObjectsFile<T> implements
SimpleFileReader<T> {
public List<T> readWithIOException(String fileName, @Nullable Long
fileSize)
throws IOException {
return readWithIOException(
- fileName,
- fileSize,
- Filter.alwaysTrue(),
- Filter.alwaysTrue(),
- Filter.alwaysTrue(),
- Function.identity());
+ fileName, fileSize, Filter.alwaysTrue(), Filter.alwaysTrue(),
Function.identity());
}
public boolean exists(String fileName) {
@@ -136,13 +126,11 @@ public abstract class ObjectsFile<T> implements
SimpleFileReader<T> {
public <R> List<R> read(
String fileName,
@Nullable Long fileSize,
- Filter<InternalRow> loadFilter,
Filter<InternalRow> readFilter,
Filter<T> readTFilter,
Function<T, R> convertor) {
try {
- return readWithIOException(
- fileName, fileSize, loadFilter, readFilter, readTFilter,
convertor);
+ return readWithIOException(fileName, fileSize, readFilter,
readTFilter, convertor);
} catch (IOException e) {
throw new RuntimeException("Failed to read " + fileName, e);
}
@@ -153,19 +141,12 @@ public abstract class ObjectsFile<T> implements
SimpleFileReader<T> {
@Nullable Long fileSize,
Filter<InternalRow> readFilter,
Filter<T> readTFilter) {
- return read(
- fileName,
- fileSize,
- Filter.alwaysTrue(),
- readFilter,
- readTFilter,
- Function.identity());
+ return read(fileName, fileSize, readFilter, readTFilter,
Function.identity());
}
private <R> List<R> readWithIOException(
String fileName,
@Nullable Long fileSize,
- Filter<InternalRow> loadFilter,
Filter<InternalRow> readFilter,
Filter<T> readTFilter,
Function<T, R> convertor)
