flink滑动窗口设置参数问题 ?
比如我要设置一个每天4点到10点的聚合统计,window算子应该怎么设置?
是滑动窗口么 size 6h 步长 多少? 偏移量呢? 有点迷惑
flink滑动窗口设置参数问题 ?
- 写回答
- 好问题 0 提建议
- 关注问题
- 邀请回答
-
1条回答 默认 最新
你说的相遇 2023-07-26 18:10关注窗口大小(Size):统计的时间范围为6个小时(从4点到10点),因此窗口大小应该设置为6小时。
步长(Stride):滑动窗口的步长表示两个相邻窗口之间的时间间隔。如果希望每小时进行一次统计,步长应该设置为1小时。
偏移量(Offset):偏移量是相对于时间轴的起点进行调整的参数,用于确定第一个窗口的起始时间。如果想要从当天的4点开始统计,偏移量应该设置为4小时。
解决 无用评论 打赏 举报