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

Posted by Jingsong Li 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-tp33888p33893.html

Hi,

Maybe you have some misunderstanding to upsert sink. You can take a look to [1], it can deal with "delete" records.

[1]https://ci.apache.org/projects/flink/flink-docs-master/dev/table/streaming/dynamic_tables.html#table-to-stream-conversion

Best,

Jingsong Lee

On Wed, Mar 25, 2020 at 11:37 AM Jingsong Li <[hidden email]> wrote:

Hi,

This can be a upsert stream [1], and JDBC has upsert sink now [2].

[1]https://ci.apache.org/projects/flink/flink-docs-master/dev/table/streaming/dynamic_tables.html#table-to-stream-conversion

[2]https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connect.html#jdbc-connector

Best,

Jingsong Lee

On Wed, Mar 25, 2020 at 11:14 AM Jingsong Li <[hidden email]> wrote:

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] 

--

Best, Jingsong Lee

--

Best, Jingsong Lee

--