liuey
2020-10-23
课程还是很详尽的
作者回复: 感谢支持,课程还是准备的很多的
4
亚索学Flink
2022-08-17
来自浙江
老师 请问 有没有python datastream api 在python中调用window的课程介绍呀,我找了flink官方文档的python例子 一直报错 里面的windowAsigner和Java的区别挺大的
Duluduluhao
2022-06-15
老师 想问一下,我最近在做窗口计算,使用SlidingProcessingTimeWindows.of(Time.seconds(300), Time.seconds(30))),发现没有新的数据会一直停留在老的五分钟的数据,这个怎么才能实现只处理最近五分钟的数据呢?
bbbi
2021-05-27
老师你好!我有一个需求是通过 datastream 接入 cdc 的数据,对数据的顺序行要求很好,为了减少对数据库的压力,我设置了基于 process time 的滚动窗口 10s 一个,有个问题是,假设因为网络或者数据库的问题,导致 w1: 00:00:00 - 00:00:10 这个窗口的process 函数用了 30s 才执行完毕,那么在这个w1执行的过程中 w2: 00:00:10 - 00:00:20 这个窗口会不会触发执行? 不知道我描述的是否清楚,就是窗口触发执行是并行的还是串行的,还是跟 trigger 有关?
共 1 条评论
淞淞同学
2021-04-12
老师~窗口计算是不是也可以理解为微批呢?
danvid
2021-03-11
keywindows是按key触发窗口计算的吧