Re: Re: Where can i find MySQL retract stream table sink java soure code？

Posted by on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Where-can-i-find-MySQL-retract-stream-table-sink-java-soure-code-tp33888p33890.html

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

---

[hidden email]

 

Sender: [hidden email]

Send Time: 2020-03-25 11:14

Receiver: [hidden email]

cc: [hidden email]

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 [hidden email] <[hidden email]> 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 status

I think this is a retract stream. 

But where can i find the java source code  about MySQL retract table sink?

Thanks,

Lei

---

[hidden email] 

--