You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by 焦童 <as...@gmail.com> on 2024/08/19 12:11:02 UTC

Flink SQL 中如何将回撤流转为append流

在Flink SQL 中如何将 retract 流中-D、-U 直接过滤  只下发+I 和 +U数据，通过写udf可以做到吗，那在udf中怎么判断当前数据是什么类型呢（+I or -D？）

Re: Flink SQL 中如何将回撤流转为append流

Posted by xiaohui zhang <xh...@gmail.com>.

修改下游的sink connector，在execute的时候把-D、-U的record去掉

Re:Flink SQL 中如何将回撤流转为append流

Posted by Xuyang <xy...@163.com>.

Hi, 在UDF中是拿不到原始数据的RowKind类型的。

可以说下你是遇到什么问题了么？用over agg/window等算子只产生append only或者自定义sink过滤-D、-U可行么？







--

    Best！
    Xuyang





在 2024-08-19 20:11:02，"焦童" <as...@gmail.com> 写道：
>在Flink SQL 中如何将 retract 流中-D、-U 直接过滤  只下发+I 和 +U数据，通过写udf可以做到吗，那在udf中怎么判断当前数据是什么类型呢（+I or -D？）