// A hopping time window with a size of 91 days and an advance interval of 1 day. // the windows are aligned with epoch long windowSizeMs = TimeUnit.DAYS.toMillis(91); long advanceMs = TimeUnit.DAYS.toMillis(1); TimeWindows timeWindows = TimeWindows.of(windowSizeMs).advanceBy(advanceMs);