lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-1773] HoodieFileGroup code optimize (#2781)

Browse Source
This commit is contained in:
hiscat
2021-04-07 18:16:03 +08:00
committed by GitHub
parent f4f9dd9d83
commit 3a926aacf6
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieFileGroup.java
View File

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