yuxiqian commented on code in PR #3801:
URL: https://github.com/apache/flink-cdc/pull/3801#discussion_r1895591572
##########
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/source/DataSource.java:
##########
@@ -36,4 +37,18 @@ public interface DataSource {
default SupportedMetadataColumn[] supportedMetadataColumns() {
return new SupportedMetadataColumn[0];
}
+
+ /**
+ * Indicating if this source guarantees for each TableId, it will not be
evolved differently
+ * among subTasks. If returns {@code false}, you'll get a regular operator
topology that is
+ * compatible with single-incremented sources like MySQL. Returns {@code
true} for sources that
+ * does not maintain a globally sequential schema change events stream,
like MongoDB or Kafka.
+ * <br>
+ * Note that new topology still an experimental feature. Return {@code
false} by default to
+ * avoid unexpected behaviors.
+ */
+ @Experimental
+ default boolean canContainDistributedTables() {
Review Comment:
Good point, I'll take the first one.
--
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]
