Flink SQL之Retraction(撤回流)

什麼是retraction（撤回） 通俗講retract就是傳統數據裏面的更新操做，也就是說retract是流式計算場景下對數據更新的處理方式。javascript 首先來看下流場景下的一個詞頻統計列子。java 沒有retract會致使最終結果不正確↑：sql  經過上面兩個圖能夠很清楚的看到retract的做用,下面咱們看一個具體的demo;apache package flink impo

>>阅读原文<<