flink實戰——flinkSQL 追加模式與縮進模式（toRetractStream）的區別

簡介          使用flinkSQL處理實時數據當我們把錶轉化成流的時候，需要使用toAppendStream與toRetractStream這兩個方法。稍不注意可能直接選擇了toAppendStream。這個兩個方法還是有很大區別的，下面具體介紹。 toAppendStream與toRetractStream的區別 追加模式：只有在動態Table僅通過INSERT更改修改時才能使用此模式

>>阅读原文<<