cshuo commented on code in PR #18485:
URL: https://github.com/apache/hudi/pull/18485#discussion_r3056119758
##########
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/event/WriteMetadataEvent.java:
##########
@@ -121,6 +121,21 @@ public void mergeWith(WriteMetadataEvent other) {
this.writeStatuses = mergeWriteStatuses(this.writeStatuses,
other.writeStatuses);
}
+ /**
+ * Merges this event with given {@link WriteMetadataEvent} {@code other}
with rescaling.
+ * The events usually come from different tasks.
+ *
+ * @param other The event to be merged
+ */
+ public WriteMetadataEvent mergeWithRescale(WriteMetadataEvent other) {
+ // the instant time could be monotonically increasing
Review Comment:
It's aligned with `mergeWith` method.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
