You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by xu...@apache.org on 2025/12/10 17:46:06 UTC
(hudi) branch master updated: refactor: remove unused method in IncrementalInputSplits (#17545)
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 <hu...@gmail.com>
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()))