Hi, I'm reworking an existing UpsertStreamTableSink into the new DynamicTableSink API. In the previous API, one would get the unique keys for upsert queries via the `setKeyFields` method, which would calculate them based on the grouping keys during the translation phase.
Searching around, I saw that JDBC ( https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/connectors/jdbc.html#key-handling) relies on explicit key passing via the PRIMARY KEY constraint. However, this would require additional manual insertion which I am trying to avoid. What would be the proper way to receive the unique keys for upsert queries with the new DynamicTableSink API? -- Best Regards, Yuval Itzchakov.
