·

数据如果要重复使用应该是存 mysql 之类的关系型数据库,flink 的基本 window 概念学一下,用 connector 连接 mysql 消费数据,实时输出结果

Replies
1

大佬,我在解题的时候希望使用自定义的flatmap和定义状态来计数,按照事件时间开24小时窗口,但是map flatmap 操作都需要在开窗前面且开窗要进行sum 才不会报错,对flink学习不够,查找资料也没有找到,所以来这里请教了。 sob 感谢。