raminqaf commented on code in PR #28235:
URL: https://github.com/apache/flink/pull/28235#discussion_r3311159207
##########
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/TableSemantics.java:
##########
@@ -128,6 +128,28 @@ public interface TableSemantics {
*/
Optional<ChangelogMode> changelogMode();
+ /**
+ * Upsert key columns derived from the passed table's metadata.
+ *
+ * <p>Returns 0-based column indices that uniquely identify a row for
upsert semantics. This is
+ * distinct from {@link #partitionByColumns()}: partition keys describe
distribution and
+ * co-location, upsert keys describe row identity. Useful for functions
that need to emit
+ * key-only deletes, match UPDATE_BEFORE / UPDATE_AFTER pairs, or route
CDC events without
+ * forcing the caller to repeat the key via {@code PARTITION BY}.
Review Comment:
Updated with the new List<int[]> API
--
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]
