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

Flink的Watermark

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

  • 写回答

2条回答 默认 最新

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

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

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

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

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

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

报告相同问题?

问题事件

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

悬赏问题

  • ¥50 深度学习运行代码直接中断
  • ¥15 关于#单片机#的问题,请各位专家解答!
  • ¥15 关于#单片机#的问题,请各位专家解答!
  • ¥20 需要完整的共散射点成像代码
  • ¥15 编写vba代码实现数据录入工作
  • ¥15 做过TCL海信电视小米电视相关影视会员软件私我
  • ¥15 Mapreduce是正常的,在运行其他jar包时并没有任何问题,只是在做LogCount.jar 时出的问题。如图所示
  • ¥15 ImportError: DLL load failed while importing _iterative: 找不到指定的模块。
  • ¥15 如何通过交互分析得出某高危患者对放疗获益更多
  • ¥15 相关性分析中,p<0.05, r=0.29,怎么评价相关性呢