热门标签
更多>
搜索结果
查询Tags标签: changelogNormalize,共有 2条记录-
flink sql upsert kafka对于changelogNormalize state解读
flink sql upsert kafka对于changelogNormalize state解读原文:https://www.jianshu.com/p/5ffe5aa0dc59这里说一点: flink sql - upsert kafka 去重并非在kafka-connector中实现,而是在这个DeduplicateFunctionBase父类中的ValueState进行keyby状态去重的,因此为何up…
2021/7/21 2:05:59 人评论 次浏览 -
flink sql upsert kafka对于changelogNormalize state解读
flink sql upsert kafka对于changelogNormalize state解读原文:https://www.jianshu.com/p/5ffe5aa0dc59这里说一点: flink sql - upsert kafka 去重并非在kafka-connector中实现,而是在这个DeduplicateFunctionBase父类中的ValueState进行keyby状态去重的,因此为何up…
2021/7/21 2:05:59 人评论 次浏览