[
https://issues.apache.org/jira/browse/HUDI-5481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ethan Guo updated HUDI-5481:
----------------------------
Description:
{code:java}
public HoodieDefaultTimeline mergeTimeline(HoodieDefaultTimeline timeline) {
Stream<HoodieInstant> instantStream = Stream.concat(instants.stream(),
timeline.getInstants()).sorted();
Function<HoodieInstant, Option<byte[]>> details = instant -> {
if (instants.stream().anyMatch(i -> i.equals(instant))) {
return this.getInstantDetails(instant);
} else {
return timeline.getInstantDetails(instant);
}
};
return new HoodieDefaultTimeline(instantStream, details);
} {code}
> Revisit the merging of HoodieDefaultTimeline
> --------------------------------------------
>
> Key: HUDI-5481
> URL: https://issues.apache.org/jira/browse/HUDI-5481
> Project: Apache Hudi
> Issue Type: Improvement
> Reporter: Ethan Guo
> Priority: Major
>
>
> {code:java}
> public HoodieDefaultTimeline mergeTimeline(HoodieDefaultTimeline timeline) {
> Stream<HoodieInstant> instantStream = Stream.concat(instants.stream(),
> timeline.getInstants()).sorted();
> Function<HoodieInstant, Option<byte[]>> details = instant -> {
> if (instants.stream().anyMatch(i -> i.equals(instant))) {
> return this.getInstantDetails(instant);
> } else {
> return timeline.getInstantDetails(instant);
> }
> };
> return new HoodieDefaultTimeline(instantStream, details);
> } {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
