Skip to content

Commit 25cc345

Browse files
committed
extract outputformat
1 parent 3832dca commit 25cc345

7 files changed

Lines changed: 492 additions & 381 deletions

File tree

mysql/mysql-sink/src/main/java/com/dtstack/flink/sql/sink/mysql/MysqlSink.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@
2020
package com.dtstack.flink.sql.sink.mysql;
2121

2222

23+
import com.dtstack.flink.sql.sink.IStreamSinkGener;
2324
import com.dtstack.flink.sql.sink.rdb.RdbSink;
2425

2526
import java.util.List;
@@ -32,7 +33,7 @@
3233
* @author xuchao
3334
*/
3435

35-
public class MysqlSink extends RdbSink {
36+
public class MysqlSink extends RdbSink implements IStreamSinkGener<RdbSink> {
3637

3738
private static final String MYSQL_DRIVER = "com.mysql.jdbc.Driver";
3839

rdb/rdb-sink/src/main/java/com/dtstack/flink/sql/sink/rdb/DBSink.java

Lines changed: 0 additions & 213 deletions
This file was deleted.

0 commit comments

Comments
 (0)