问答 2023-05-09 来自:开发者社区

向大佬们请教一下 ,FLinkCDC监听MySQL数据后,再通过FLinkSQL TUMBLE窗口

向大佬们请教一下 ,FLinkCDC监听MySQL数据后,再通过FLinkSQL TUMBLE窗口聚合后数据操作类型都变成 +I ,这个是什么原理?上游聚合产生的新数据对吗?做实时大屏,订单太多 ,做一下分类和时间窗口聚合 推送到大屏上,有insert 有update,我只想要某个状态的订单,在where条件上加上订单状态就可以过滤掉吗?好像我之前的没去掉insert操作的时候数据都sink...

问答 2022-02-15 来自:开发者社区

请问使用debe监听mysql 到kafka,怎么使用窗口统计每日增量?#Flink

请问使用debe监听mysql 到kafka,怎么使用窗口统计每日增量?#Flink

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。