Details
-
Improvement
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
Description
Today, the output timestamp for a combined value (including iterables output by GroupByKey) is the earliest non-late timestamp of any element combined together. The user can customize this by specifying an OutputTimeFn, for example choosing the latest non-late timestamp, or the end of the window.
In many respects, the end of the window is the best behaved as a default, and is very easy to make performant. We have deferred making this change for backwards compatibility; this is a good time to do so.