• 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触发窗口计算的吧
    
    