gustavodemorais commented on code in PR #27847:
URL: https://github.com/apache/flink/pull/27847#discussion_r3008435098
##########
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/PartitionedTable.java:
##########
@@ -159,6 +159,12 @@ public interface PartitionedTable {
* descriptor("op_code").asArgument("op"),
* map("INSERT", "I", "UPDATE_AFTER", "U").asArgument("op_mapping")
* );
+ *
+ * // Deletion flag pattern: comma-separated keys map multiple change
operations to the same code
Review Comment:
Thanks for the review, Feat Zhang. The existing JavaDoc and documentation
already explain that unmapped operations are dropped. Adding
UPDATE_BEFORE-specific details to the generic toChangelog() JavaDoc would be
too narrow, since it depends on the use case
--
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]
