From 7c4ac0543e9e47acc7749e42a8b5deedef8f07bb Mon Sep 17 00:00:00 2001 From: Nishith Agarwal Date: Tue, 25 Jul 2017 17:25:41 -0700 Subject: [PATCH] Use CompletedFileSystemView instead of CompactedView considering deltacommits --- .../src/main/java/com/uber/hoodie/io/HoodieCleanHelper.java | 2 +- .../src/main/java/com/uber/hoodie/table/HoodieTable.java | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/hoodie-client/src/main/java/com/uber/hoodie/io/HoodieCleanHelper.java b/hoodie-client/src/main/java/com/uber/hoodie/io/HoodieCleanHelper.java index a5a5129cbc10b..eb9fdca9accb8 100644 --- a/hoodie-client/src/main/java/com/uber/hoodie/io/HoodieCleanHelper.java +++ b/hoodie-client/src/main/java/com/uber/hoodie/io/HoodieCleanHelper.java @@ -59,7 +59,7 @@ public class HoodieCleanHelper> { public HoodieCleanHelper(HoodieTable hoodieTable, HoodieWriteConfig config) { this.hoodieTable = hoodieTable; - this.fileSystemView = hoodieTable.getCompactedFileSystemView(); + this.fileSystemView = hoodieTable.getCompletedFileSystemView(); this.commitTimeline = hoodieTable.getCompletedCommitTimeline(); this.config = config; this.fs = hoodieTable.getFs(); diff --git a/hoodie-client/src/main/java/com/uber/hoodie/table/HoodieTable.java b/hoodie-client/src/main/java/com/uber/hoodie/table/HoodieTable.java index 26077407445b5..9e8c2ab2cde8d 100644 --- a/hoodie-client/src/main/java/com/uber/hoodie/table/HoodieTable.java +++ b/hoodie-client/src/main/java/com/uber/hoodie/table/HoodieTable.java @@ -127,12 +127,12 @@ public TableFileSystemView.RealtimeView getRTFileSystemView() { } /** - * Get the view of the file system for this table + * Get the completed (commit + compaction) view of the file system for this table * * @return */ - public TableFileSystemView getCompactedFileSystemView() { - return new HoodieTableFileSystemView(metaClient, getCompletedCompactionCommitTimeline()); + public TableFileSystemView getCompletedFileSystemView() { + return new HoodieTableFileSystemView(metaClient, getCommitTimeline()); } /**