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

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

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

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

退订

2024-08-19 文章 阿里云系统
退订 发自我的 iPhone