diff --git a/hudi-common/src/main/java/org/apache/hudi/common/table/view/AbstractTableFileSystemView.java b/hudi-common/src/main/java/org/apache/hudi/common/table/view/AbstractTableFileSystemView.java index eca3718f1..b0687bb35 100644 --- a/hudi-common/src/main/java/org/apache/hudi/common/table/view/AbstractTableFileSystemView.java +++ b/hudi-common/src/main/java/org/apache/hudi/common/table/view/AbstractTableFileSystemView.java @@ -125,7 +125,7 @@ public abstract class AbstractTableFileSystemView implements SyncableFileSystemV /** * Adds the provided statuses into the file system view, and also caches it inside this object. */ - protected List addFilesToView(FileStatus[] statuses) { + public List addFilesToView(FileStatus[] statuses) { HoodieTimer timer = new HoodieTimer().startTimer(); List fileGroups = buildFileGroups(statuses, visibleCommitsAndCompactionTimeline, true); long fgBuildTimeTakenMs = timer.endTimer(); @@ -925,7 +925,7 @@ public abstract class AbstractTableFileSystemView implements SyncableFileSystemV /** * Default implementation for fetching latest base-files for the partition-path. */ - Stream fetchLatestBaseFiles(final String partitionPath) { + public Stream fetchLatestBaseFiles(final String partitionPath) { return fetchAllStoredFileGroups(partitionPath) .map(fg -> Pair.of(fg.getFileGroupId(), getLatestBaseFile(fg))) .filter(p -> p.getValue().isPresent())