Or you can build your own Sink code, where you can delete rows of DB table.
Best, JingsongLee
--
From:Papadopoulos, Konstantinos
Send Time:2019年5月28日(星期二) 22:54
To:Vasyl Bervetskyi
Cc:user@flink.apache.org
Subject:RE: Fli
: Flink SQL: Execute DELETE queries
Hi Papadopoulos,
Unfortunately no, there is no DELETE or MODIFY queries, you should create new
table as a result of query which will filter records from existing one
From: Papadopoulos, Konstantinos
mailto:konstantinos.papadopou...@iriworldwide.com>>
Hi Papadopoulos,
Unfortunately no, there is no DELETE or MODIFY queries, you should create new
table as a result of query which will filter records from existing one
From: Papadopoulos, Konstantinos
Sent: Tuesday, May 28, 2019 5:25 PM
To: user@flink.apache.org
Subject: Flink SQL: Execute
Hi all,
I experiment on Flink Table API & SQL and I have the following question; is
there any way to execute DELETE queries using Flink SQL?
Thanks in advance,
Konstantinos
