[hudi] branch master updated: [HUDI-1773] HoodieFileGroup code optimize (#2781)

[vinoyang]

This is an automated email from the ASF dual-hosted git repository.

vinoyang 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 3a926aa  [HUDI-1773] HoodieFileGroup code optimize (#2781)
3a926aa is described below

commit 3a926aacf6552fc06005db4a7880a233db904330
Author: hiscat <46845236+mylanpan...@users.noreply.github.com>
AuthorDate: Wed Apr 7 18:16:03 2021 +0800

    [HUDI-1773] HoodieFileGroup code optimize (#2781)
---
 .../main/java/org/apache/hudi/common/model/HoodieFileGroup.java    | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git 
a/hudi-common/src/main/java/org/apache/hudi/common/model/HoodieFileGroup.java 
b/hudi-common/src/main/java/org/apache/hudi/common/model/HoodieFileGroup.java
index 849f08e..6979c30 100644
--- 
a/hudi-common/src/main/java/org/apache/hudi/common/model/HoodieFileGroup.java
+++ 
b/hudi-common/src/main/java/org/apache/hudi/common/model/HoodieFileGroup.java
@@ -26,7 +26,6 @@ import org.apache.hudi.common.util.collection.Pair;
 import java.io.Serializable;
 import java.util.Comparator;
 import java.util.List;
-import java.util.Map;
 import java.util.TreeMap;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
@@ -133,7 +132,7 @@ public class HoodieFileGroup implements Serializable {
    * Get all the the file slices including in-flight ones as seen in 
underlying file-system.
    */
   public Stream<FileSlice> getAllFileSlicesIncludingInflight() {
-    return fileSlices.entrySet().stream().map(Map.Entry::getValue);
+    return fileSlices.values().stream();
   }
 
   /**
@@ -148,7 +147,7 @@ public class HoodieFileGroup implements Serializable {
    */
   public Stream<FileSlice> getAllFileSlices() {
     if (!timeline.empty()) {
-      return 
fileSlices.entrySet().stream().map(Map.Entry::getValue).filter(this::isFileSliceCommitted);
+      return fileSlices.values().stream().filter(this::isFileSliceCommitted);
     }
     return Stream.empty();
   }
@@ -182,7 +181,7 @@ public class HoodieFileGroup implements Serializable {
    * Obtain the latest file slice, upto an instantTime i.e < maxInstantTime.
    * 
    * @param maxInstantTime Max Instant Time
-   * @return
+   * @return the latest file slice
    */
   public Option<FileSlice> getLatestFileSliceBefore(String maxInstantTime) {
     return Option.fromJavaOptional(getAllFileSlices().filter(