MehulBatra commented on code in PR #2525:
URL: https://github.com/apache/fluss/pull/2525#discussion_r2751324623
##########
fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/FlinkConnectorOptions.java:
##########
@@ -245,7 +245,16 @@ public class FlinkConnectorOptions {
.withDescription(
"The serialized base64 bytes of refresh handler of
materialized table.");
- //
------------------------------------------------------------------------------------------
+ /**
+ * Internal option used to pass the base table's partition key column
names to the binlog table
+ * source. The value is a comma-separated list of column names.
+ */
+ public static final ConfigOption<String> BINLOG_PARTITION_KEYS =
+ ConfigOptions.key("binlog.partition-keys")
Review Comment:
I renamed and reintroduced as to address BINLOG_IS_PARTITIONED indicate
whether the base table is partitioned for $binlog sources.
--
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]
