danny0405 commented on code in PR #13600:
URL: https://github.com/apache/hudi/pull/13600#discussion_r2252949767
##########
hudi-common/src/main/java/org/apache/hudi/common/table/read/BufferedRecordMergerFactory.java:
##########
@@ -402,27 +410,46 @@ public MergeResult<T>
mergeNonDeleteRecord(BufferedRecord<T> olderRecord, Buffer
}
}
+ /**
+ * An implementation of {@link BufferedRecordMerger} which merges {@link
BufferedRecord}s based on the ExpressionPayload.
+ * The delta merge expects the incoming records to both be Expression
Payload, whereas the final merge expects the existing
+ * record payload to match the table's configured payload and the new record
to be an Expression Payload.
+ */
+ private static class ExpressionPayloadRecordMerger<T> extends
CustomPayloadRecordMerger<T> {
Review Comment:
+1, thanks for the effort.
--
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]
