fresh-borzoni commented on code in PR #2042:
URL: https://github.com/apache/fluss/pull/2042#discussion_r2682030472
##########
fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/sink/FlussSinkBuilder.java:
##########
@@ -98,6 +102,23 @@ public FlussSinkBuilder<InputT>
setShuffleByBucketId(boolean shuffleByBucketId)
return this;
}
+ /**
+ * Enable partial update by specifying the column names to update for
upsert tables. Primary key
+ * columns must be included in this list.
+ */
+ public FlussSinkBuilder<InputT> setPartialUpdateColumns(List<String>
columns) {
+ this.partialUpdateColumns = columns;
Review Comment:
should we defensively copy here, otherwise caller has chance to modify
passed list?
--
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]
