Flink 1.7.2 业务时间戳分析流式数据源码分析

  • 时间:
  • 浏览:0

分配Window,也只是我计算Window的开启时间和刚开始了时间,该计算最好的办法 ,算法,恰好把所有元素都分配到整size的时间段

如size = 5秒,40000毫秒,也只是我时间戳在什么范围内的,就会被分配的最近的有一另4个区间