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
