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-tp33888p33891.html

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 

---

[hidden email] 

 

Sender: [hidden email]

Send Time: 2020-03-25 11:25

Receiver: [hidden email]

cc: [hidden email]

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

---

[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] 

--