【Flink实战系列】Flink SQL 之 Retraction (回撤流)_flink 回撤流使用

作者：你好赵伟 | 2024-04-07 23:28:34

踩

flink 回撤流使用

通俗讲retract就是传统数据里面的更新操作，也就是说retract是流式计算场景下对数据更新的处理方式。

首先来看下流场景下的一个词频统计列子。

没有retract会导致最终结果不正确↑：

通过上面两个图可以很清楚的看到retract的作用,下面我们看一个具体的demo;


package flink
 
import java.util.Properties
import com.alibaba.fastjson.JSON
import org.apache.flink.api.common.serialization.Simpl

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/你好赵伟/article/detail/381363