Skip to content

Commit 7a498c9

Browse files
committed
add output package
1 parent 379b9a5 commit 7a498c9

File tree

2 files changed

+2
-7
lines changed

2 files changed

+2
-7
lines changed

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

-5
Original file line numberDiff line numberDiff line change
@@ -78,10 +78,5 @@ public String getDriverName() {
7878
return MYSQL_DRIVER;
7979
}
8080

81-
@Override
82-
public RetractJDBCOutputFormat getOutputFormat() {
83-
return new RetractJDBCOutputFormat();
84-
}
85-
8681

8782
}

rdb/rdb-sink/src/main/java/com/dtstack/flink/sql/sink/rdb/RetractJDBCOutputFormat.java renamed to rdb/rdb-sink/src/main/java/com/dtstack/flink/sql/sink/rdb/format/RetractJDBCOutputFormat.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -16,8 +16,9 @@
1616
* limitations under the License.
1717
*/
1818

19-
package com.dtstack.flink.sql.sink.rdb;
19+
package com.dtstack.flink.sql.sink.rdb.format;
2020

21+
import com.dtstack.flink.sql.sink.rdb.RdbSink;
2122
import org.apache.commons.lang3.StringUtils;
2223
import org.apache.flink.api.java.tuple.Tuple;
2324
import org.apache.flink.api.java.tuple.Tuple2;
@@ -27,7 +28,6 @@
2728
import org.apache.flink.types.Row;
2829
import org.slf4j.Logger;
2930
import org.slf4j.LoggerFactory;
30-
3131
import java.sql.*;
3232
import java.util.*;
3333
import java.io.IOException;

0 commit comments

Comments
 (0)