60-150-044-使用-Sink-Flink自定義RetractStreamTableSink

1.美圖 2. 概述 ​ Flink Table/SQL中對於流表TableSink的定義有三類：AppendStreamTable、RetractStreamTableSink 、UpsertStreamTableSink ，這三類主要區別對應不同的流類型，在我看來可以歸納爲兩種模式： Insert模式，對應AppendStreamTable，只能執行insert動作，例如窗口聚合結果，每個窗口

>>阅读原文<<