Flink 窗口问题

我想在Flink中统计每天处理的数据量,想法是使用窗口来实现,但是不知道如何设定开始时间与截止时间,例如我想统计每天从0点开始这一天内处理的数据量

罗江宇

赞同来自: wangxiaolei

window比较小的区间比较适合,至于一天,还有区间不固定不太适合,可以考虑keyBy + processFunction, 通过flink 的状态来做计算

要回复问题请先登录注册