etract mode not
> available yet. It is right？
>
> Thanks,
> Lei
>
>
> --
> wangl...@geekplus.com.cn
>
>
> *Sender:* Jingsong Li
> *Send Time:* 2020-03-25 11:39
> *Receiver:* wangl...@geekplus.com.cn
> *cc:* user
> *Subject
retract stream table sink java soure code？
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-conver
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
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
Be
om.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
: 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
wrote:
Create one table with kafka, another table with MySQL
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 my
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)
