Hi guys, We are trying use Flink to count millions of keyed items of an hour window hourly as `time(SlidingEventTimeWindows.of(1hour, 1hour))`. According to the sliding window doc <https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/windows.html#sliding-windows>, all windows are aligned with epoch and always start at integral hours like 1:00:00.000 - 1:59:59.999.
But we actually want to start an hour window whenever an new item arrives. For example, - for item A, the first event arrives at 1:12:24.123, so the window would be 1:12:24.123 - 2:12:24.122, and the next window would be 2:12:24.123 - 3:12:24.122, and so on - for item B, the first event arrives at 1:10:20:321, so the window would be 1:10:20:321 - 2:10:20:320, and the next window would be 2:10:20:321 - 3:10:20:320, and so on. Do you have any insights on how to achieve it? Thanks! Bowen
