数据划分窗口

image.png

  1. package org.apache.flink.streaming.api.windowing.windows;
  3. /**
  4.  * A {@link Window} that represents a time interval from {@code start} (inclusive) to {@code end}
  5.  * (exclusive).
  6.  */
  7. @PublicEvolving
  8. public class TimeWindow extends Window {
  9.     /**
  10.      * Method to get the window start for a timestamp.
  11.      *
  12.      * @param timestamp epoch millisecond to get the window start.
  13.      * @param offset The offset which window start would be shifted by.
  14.      * @param windowSize The size of the generated windows.
  15.      * @return window start
  16.      */
  17.     public static long getWindowStartWithOffset(long timestamp, long offset, long windowSize) {
  18.         return timestamp - (timestamp - offset + windowSize) % windowSize;
  19.     }
  21. }

数据划分到窗口时，窗口是左闭右开的，相关代码在上面的类中