Flink SQL之Retraction(撤回流)

什么是retraction（撤回） 通俗讲retract就是传统数据里面的更新操做，也就是说retract是流式计算场景下对数据更新的处理方式。javascript 首先来看下流场景下的一个词频统计列子。java 没有retract会致使最终结果不正确↑：sql  经过上面两个图能够很清楚的看到retract的做用,下面咱们看一个具体的demo;apache package flink impo

>>阅读原文<<