This is an automated email from the ASF dual-hosted git repository.
xushiyan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new b1030359c69b refactor: remove unused method in IncrementalInputSplits
(#17545)
b1030359c69b is described below
commit b1030359c69b46ef5e920ff63719b13b3a5087e4
Author: Peter Huang <[email protected]>
AuthorDate: Wed Dec 10 09:45:49 2025 -0800
refactor: remove unused method in IncrementalInputSplits (#17545)
---
.../java/org/apache/hudi/source/IncrementalInputSplits.java | 10 ----------
1 file changed, 10 deletions(-)
diff --git
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/IncrementalInputSplits.java
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/IncrementalInputSplits.java
index c7dd6dcdf9b2..4258a49a36ed 100644
---
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/IncrementalInputSplits.java
+++
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/IncrementalInputSplits.java
@@ -63,7 +63,6 @@ import java.util.Set;
import java.util.TreeSet;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.stream.Collectors;
-import java.util.stream.Stream;
/**
* Utilities to generate incremental input splits {@link
MergeOnReadInputSplit}.
@@ -408,15 +407,6 @@ public class IncrementalInputSplits implements
Serializable {
.collect(Collectors.toList());
}
- private static Stream<FileSlice> getFileSlices(
- HoodieTableFileSystemView fsView,
- String relPartitionPath,
- String endInstant,
- boolean skipBaseFiles) {
- return skipBaseFiles ?
fsView.getAllLogsMergedFileSliceBeforeOrOn(relPartitionPath, endInstant)
- : fsView.getLatestMergedFileSlicesBeforeOrOn(relPartitionPath,
endInstant);
- }
-
private FileIndex getFileIndex(HoodieTableMetaClient metaClient) {
return FileIndex.builder()
.path(new StoragePath(path.toUri()))
