开发者社区> 问答> 正文

我使用了一个window算子,窗口大小是30s,并且使用trigger 设置每秒输出结果#Flink

我使用了一个window算子,窗口大小是30s,并且使用trigger 设置每秒输出结果,怎么区别是30秒窗口输出的结果,还是每秒触发的结果? #Flink

展开
收起
黄一刀 2020-05-26 20:32:51 597 0
1 条回答
写回答
取消 提交回答
  • 区分不了的,window.getStart()/getEnd()返回的都是窗口真实的开始和结束时间,因为触发器就是让窗口提前fire而已,窗口本身不能变的。。如果getStart()/getEnd()返回的不一样,窗口语义就乱了

    2020-05-27 10:19:31
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载