yihua commented on code in PR #9883:
URL: https://github.com/apache/hudi/pull/9883#discussion_r1375668820
##########
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieRecordMerger.java:
##########
@@ -43,9 +44,27 @@ public interface HoodieRecordMerger extends Serializable {
* This method converges combineAndGetUpdateValue and precombine from
HoodiePayload.
* It'd be associative operation: f(a, f(b, c)) = f(f(a, b), c) (which we
can translate as having 3 versions A, B, C
* of the single record, both orders of operations applications have to
yield the same result)
+ * This method takes only full records for merging.
*/
Option<Pair<HoodieRecord, Schema>> merge(HoodieRecord older, Schema
oldSchema, HoodieRecord newer, Schema newSchema, TypedProperties props) throws
IOException;
+ /**
+ * Merges records which can contain partial updates, i.e., only subset of
fields and values are
+ * present in the record representing the updates, and absent fields are not
updated.
Review Comment:
Examples added in docs.
--
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]
