Skip to content

Commit 145b617

Browse files
Tuplezhangchaoming.zcm
authored andcommitted
[mysql] Add a method to get MySqlSourceConfigFactory from MySqlSource (apache#648)
1 parent 22209cd commit 145b617

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/MySqlSource.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@
7575
*
7676
* <pre>{@code
7777
* MySqlSource
78-
* .<RowData>builder()
78+
* .<String>builder()
7979
* .hostname("localhost")
8080
* .port(3306)
8181
* .databaseList("mydb")
@@ -117,6 +117,10 @@ public static <T> MySqlSourceBuilder<T> builder() {
117117
this.deserializationSchema = deserializationSchema;
118118
}
119119

120+
public MySqlSourceConfigFactory getConfigFactory() {
121+
return configFactory;
122+
}
123+
120124
@Override
121125
public Boundedness getBoundedness() {
122126
return Boundedness.CONTINUOUS_UNBOUNDED;

0 commit comments

Comments
 (0)