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

[焦童]

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