From fe57e9beea54ac54ac0c0d204b7338deb7f36369 Mon Sep 17 00:00:00 2001 From: Sagar Sumit Date: Mon, 22 Nov 2021 22:53:50 +0530 Subject: [PATCH] [HUDI-2599] Make addFilesToview and fetchLatestBaseFiles public (#4066) --- .../hudi/common/table/view/AbstractTableFileSystemView.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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())