开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

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

向大佬们请教一下 ,FLinkCDC监听MySQL数据后,再通过FLinkSQL TUMBLE窗口聚合后数据操作类型都变成 +I ,这个是什么原理?上游聚合产生的新数据对吗?做实时大屏,订单太多 ,做一下分类和时间窗口聚合 推送到大屏上,有insert 有update,我只想要某个状态的订单,在where条件上加上订单状态就可以过滤掉吗?好像我之前的没去掉insert操作的时候数据都sink下去了 ,我主要是想实现通过可视化拖拉拽组合流计算逻辑,然后在线将组合好的逻辑生成jar包上传至flink,简单说就是通过web项目管理flink

展开
收起
真的很搞笑 2023-05-09 13:23:41 137 0
1 条回答
写回答
取消 提交回答
  • 我觉得就不需要关心操作类型,spring本身对于flink不就是个累赘吗,需要他做什么能,此回答整理自钉群“Flink CDC 社区”

    2023-05-09 13:36:17
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

热门讨论

热门文章

相关电子书

更多
搭建电商项目架构连接MySQL 立即下载
搭建4层电商项目架构,实战连接MySQL 立即下载
PolarDB MySQL引擎重磅功能及产品能力盛大发布 立即下载

相关镜像