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 status > > I 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
