我爱夜来香A 2023-03-28 20:55 采纳率: 22.2%
浏览 11
已结题

Flink的Watermark

Flink中的水位线是动态生成的,watermark = 进入窗口的最大事件时间-允许延迟的时间,当watermark时间戳大于等于窗口结束时间时,意味着窗口结束,需要触发窗口计算,请问窗口开始时间和结束时间是怎么计算的?

  • 写回答

2条回答 默认 最新

  • 我爱夜来香A 大数据领域新星创作者 2023-04-18 13:44
    关注

    对于时间窗口,开始时间和结束时间的计算方式如下:

    滚动时间窗口:按照固定的时间长度对数据进行分组,窗口的大小和滑动步长相同,例如,5秒的滚动窗口,每5秒钟计算一次。开始时间为当前窗口大小的整数倍,结束时间为开始时间加上窗口大小。

    滑动时间窗口:按照固定的时间长度对数据进行分组,窗口的大小和滑动步长不同,例如,5秒的滑动窗口,每2秒钟滑动一次。开始时间为当前窗口大小的整数倍加上窗口滑动步长的整数倍,结束时间为开始时间加上窗口大小。

    会话窗口:按照数据的时间间隔进行分组,当两个数据之间的时间间隔大于指定的间隔时间时,就认为前一个窗口结束,后一个窗口开始。开始时间为第一个数据的时间戳,结束时间为最后一个数据的时间戳加上间隔时间。

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(1条)

报告相同问题?

问题事件

  • 系统已结题 4月26日
  • 已采纳回答 4月18日
  • 创建了问题 3月28日

悬赏问题

  • ¥20 射频功率问题,解答者有酬谢!
  • ¥80 构建降雨和积水的预测模型
  • ¥15 #Qt Transform setTransform()在鼠标拖动移动视角是一致在原地不动,无法变换视角(细微观察似乎视图有在原地抖动),无法变换视角(细微观察似乎视图有在原地抖动)
  • ¥50 如何利用无人机拍摄的数码照片测量鸟卵的长短径
  • ¥100 github贡献者给与奖励
  • ¥15 使用DS18B20+ESP8266获取温度数据返回-127.00
  • ¥15 odbc代码新增sqlserver数据源
  • ¥15 求一个USB指纹识别的驱动
  • ¥15 wps中工作表与工作表之间怎么汇总信息?
  • ¥50 请教Windows server 2012 R2的DCOM配置问题