This is an automated email from the ASF dual-hosted git repository. nagarwal 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 9b1f16b [HUDI-1136] Add back findInstantsAfterOrEquals to the HoodieTimeline class. 9b1f16b is described below commit 9b1f16b604143f5a6926db57173f9eeee21fbb6c Author: Prashant Wason <pwa...@uber.com> AuthorDate: Mon Aug 24 14:24:50 2020 -0700 [HUDI-1136] Add back findInstantsAfterOrEquals to the HoodieTimeline class. --- .../apache/hudi/common/table/timeline/HoodieDefaultTimeline.java | 7 +++++++ .../java/org/apache/hudi/common/table/timeline/HoodieTimeline.java | 5 +++++ 2 files changed, 12 insertions(+) diff --git a/hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieDefaultTimeline.java b/hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieDefaultTimeline.java index c7a6230..678d056 100644 --- a/hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieDefaultTimeline.java +++ b/hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieDefaultTimeline.java @@ -133,6 +133,13 @@ public class HoodieDefaultTimeline implements HoodieTimeline { } @Override + public HoodieDefaultTimeline findInstantsAfterOrEquals(String commitTime, int numCommits) { + return new HoodieDefaultTimeline(instants.stream() + .filter(s -> HoodieTimeline.compareTimestamps(s.getTimestamp(), GREATER_THAN_OR_EQUALS, commitTime)) + .limit(numCommits), details); + } + + @Override public HoodieDefaultTimeline findInstantsBefore(String instantTime) { return new HoodieDefaultTimeline(instants.stream() .filter(s -> HoodieTimeline.compareTimestamps(s.getTimestamp(), LESSER_THAN, instantTime)), diff --git a/hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieTimeline.java b/hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieTimeline.java index 45b9e34..b7c405e 100644 --- a/hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieTimeline.java +++ b/hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieTimeline.java @@ -141,6 +141,11 @@ public interface HoodieTimeline extends Serializable { HoodieTimeline filterPendingCompactionTimeline(); /** + * Create a new Timeline with all the instants after startTs. + */ + HoodieTimeline findInstantsAfterOrEquals(String commitTime, int numCommits); + + /** * Create a new Timeline with instants after startTs and before or on endTs. */ HoodieTimeline findInstantsInRange(String startTs, String endTs);