[hudi] branch master updated: [HUDI-1136] Add back findInstantsAfterOrEquals to the HoodieTimeline class.

[nagarwal]

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);