Hi, Jim.
1: I'm expecting all DynamicTableSinks to support. But it's hard to support all
at one shot. For the DynamicTableSinks that haven't implemented
SupportsTruncate interface, we'll throw exception
like 'The truncate statement for the table is not supported as it hasn't
implemented the interface SupportsTruncate'. Also, for some sinks that doesn't
support deleting data, it can also implements it but throw more concrete
exception like "xxx donesn't support to truncate a table as delete is
impossible for xxx". It depends on the external connector's implementation.
Thanks for your advice, I updated it to the FLIP.
2: What do you mean by saying "truncate an input to a streaming query"? This
FLIP is aimed to support TRUNCATE TABLE statement which is for truncating a
table. In which case it will inoperates with streaming queries?
Best regards,
Yuxia
----- 原始邮件 -----
发件人: "Jim Hughes" <jhug...@confluent.io.INVALID>
收件人: "dev" <dev@flink.apache.org>
发送时间: 星期一, 2023年 4 月 10日 下午 9:32:28
主题: Re: [DISCUSS] FLIP-302: Support TRUNCATE TABLE statement
Hi Yuxia,
Two questions:
1. Are you expecting all DynamicTableSinks to support Truncate? The FLIP
could use some explanation for what supporting and not supporting the
operation means.
2. How will truncate inoperate with streaming queries? That is, if I
truncate an input to a streaming query, is there any defined behavior?
Cheers,
Jim
On Wed, Mar 22, 2023 at 9:13 AM yuxia <luoyu...@alumni.sjtu.edu.cn> wrote:
> Hi, devs.
>
> I'd like to start a discussion about FLIP-302: Support TRUNCATE TABLE
> statement [1].
>
> The TRUNCATE TABLE statement is a SQL command that allows users to quickly
> and efficiently delete all rows from a table without dropping the table
> itself. This statement is commonly used in data warehouse, where large data
> sets are frequently loaded and unloaded from tables.
> So, this FLIP is meant to support TRUNCATE TABLE statement. M ore exactly,
> this FLIP will bring Flink the TRUNCATE TABLE syntax and an interface with
> which the coresponding connectors can implement their own logic for
> truncating table.
>
> Looking forwards to your feedback.
>
> [1]: [
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-302%3A+Support+TRUNCATE+TABLE+statement
> |
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-302%3A+Support+TRUNCATE+TABLE+statement
> ]
>
>
> Best regards,
> Yuxia
>
