Hi, 在UDF中是拿不到原始数据的RowKind类型的。 可以说下你是遇到什么问题了么？用over agg/window等算子只产生append only或者自定义sink过滤-D、-U可行么？
--
Best！
Xuyang
在 2024-08-19 20:11:02，"焦童" <asd994144...@gmail.com> 写道：
>在Flink SQL 中如何将 retract 流中-D、-U 直接过滤 只下发+I 和
>+U数据，通过写udf可以做到吗，那在udf中怎么判断当前数据是什么类型呢（+I or -D？）
