pFad - Phone/Frame/Anonymizer/Declutterfier! Saves Data!


--- a PPN by Garber Painting Akron. With Image Size Reduction included!

URL: http://github.com/DTStack/flinkStreamSQL/commit/25cc3451e6f40c3fd47a04c33a7fa968fd163c95

css" /> extract outputformat · DTStack/flinkStreamSQL@25cc345 · GitHub
Skip to content

Commit 25cc345

Browse files
todd5167todd5167
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)
pFad - Phonifier reborn

Pfad - The Proxy pFad © 2024 Your Company Name. All rights reserved.




Check this box to remove all script contents from the fetched content.



Check this box to remove all images from the fetched content.


Check this box to remove all CSS styles from the fetched content.


Check this box to keep images inefficiently compressed and original size.

Note: This service is not intended for secure transactions such as banking, social media, email, or purchasing. Use at your own risk. We assume no liability whatsoever for broken pages.


Alternative Proxies:

Alternative Proxy

pFad Proxy

pFad v3 Proxy

pFad v4 Proxy