[SERVER-80908] Add offset to TumblingWindow Created: 27/May/23  Updated: 29/Oct/23  Resolved: 09/Sep/23

Status: Closed
Project: Core Server
Component/s: None
Affects Version/s: None
Fix Version/s: 7.2.0-rc0

Type: New Feature Priority: Major - P3
Reporter: Robert Walters Assignee: Yoon Soo Kim
Resolution: Fixed Votes: 0
Labels: draft-improvements, init-337-m3
Remaining Estimate: Not Specified
Time Spent: Not Specified
Original Estimate: Not Specified

Issue Links:
Documented
Backwards Compatibility: Fully Compatible
Sprint: Sprint 31
Participants:

 Description   

Flink has this option to accept an optional offset parameter that can be used to change the alignment of windows.

 

Example: without offsets hourly tumbling windows are aligned with epoch, that is you will get windows such as 1:00:00.000 - 1:59:59.9992:00:00.000 - 2:59:59.999 and so on. If you want to change that you can give an offset. With an offset of 15 minutes you would, for example, get 1:15:00.000 - 2:14:59.9992:15:00.000 - 3:14:59.999 etc.

 

An important use case for offsets is to adjust windows to timezones other than UTC-0. For example, in China you would have to specify an offset of Time.hours(-8).


Generated at Thu Feb 08 06:44:55 UTC 2024 using Jira 9.7.1#970001-sha1:2222b88b221c4928ef0de3161136cc90c8356a66.