Seems it is here:
https://github.com/apache/flink/tree/master/flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc
There's no JDBCRetractTableSink, only append and upsert.
I am confused why the MySQL record can be deleted.
Thanks,
Lei
wangl...@geekplus.com.cn
Sender: wangl...@geekplus.com.cn
Send Time: 2020-03-25 11:25
Receiver: Jingsong Li
cc: user
Subject: Re: Re: Where can i find MySQL retract stream table sink java soure
code？
Thanks Jingsong.
When executing this sql, the mysql table record can be deleted. So i guess it
is a retract stream.
I want to know the exactly java code it is generated and have a look at it.
Thanks,
Lei
wangl...@geekplus.com.cn
Sender: Jingsong Li
Send Time: 2020-03-25 11:14
Receiver: wangl...@geekplus.com.cn
cc: user
Subject: Re: Where can i find MySQL retract stream table sink java soure code？
Hi,
This can be a upsert stream [1]
Best,
Jingsong Lee
On Wed, Mar 25, 2020 at 11:12 AM wangl...@geekplus.com.cn
<wangl...@geekplus.com.cn> wrote:
Create one table with kafka, another table with MySQL using flinksql.
Write a sql to read from kafka and write to MySQL.
INSERT INTO mysqlTable SELECT status, COUNT(order_no) AS num FROM
(SELECT order_no, LAST_VALUE(status) AS status FROM
kafkaTable GROUP BY order_no)
GROUP BY statusI think this is a retract stream. But
where can i find the java source code about MySQL retract table sink?
Thanks,Lei
wangl...@geekplus.com.cn
--
Best, Jingsong Lee
