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

1.美图 2. 概述 ​ Flink Table/SQL中对于流表TableSink的定义有三类:AppendStreamTable、RetractStreamTableSink 、UpsertStreamTableSink ,这三类主要区别对应不同的流类型,在我看来可以归纳为两种模式: Insert模式,对应AppendStreamTable,只能执行insert动作,例如窗口聚合结果,每个窗口
相关文章
相关标签/搜索